I think you can get around the final call to "types()" or "doJoin()" when every of those "projectX()" calls creates a ready "projectJoinOperator" that inherits from DataSet. Further calls only append more fields.
Stephan Am 04.11.2014 10:02 schrieb "Chen Xu" <[email protected]>: > >> Hi Stephan, >> >> I am working on the issue [FLINK-1040]. >> >> At first, I would like to remove type() call in projections totally. >> >> However, considering the case in JoinProjection and CrossProjection, "chaining projection" like >> >> ds1.join(ds2).where(0).equalTo(0) >> .projectSecond(2) >> .projectFirst(1) >> .types(String.class); >> >> usually happens. >> >> Of course, String.class would be extracted by compiler. >> >> However, as the final transformation are activated by types(), it seems we can turn the sharp to be >> >> ds1.join(ds2).where(0).equalTo(0) >> .projectSecond(2) >> .projectFirst(1) >> .types(); >> >> or rename types() here like doJoinProject().. >> >> Does it make sense or anything wrong here? >> >> Cheers! >> -Chen >> Xu >>
