Class CrossOperator.CrossProjection<I1,I2>
- java.lang.Object
-
- org.apache.flink.api.java.operators.CrossOperator.CrossProjection<I1,I2>
-
- Type Parameters:
I1-I2-
- Enclosing class:
- CrossOperator<I1,I2,OUT>
@Internal public static final class CrossOperator.CrossProjection<I1,I2> extends Object
- See Also:
CrossOperator.ProjectCross
-
-
Constructor Summary
Constructors Constructor Description CrossProjection(DataSet<I1> ds1, DataSet<I2> ds2, int[] firstFieldIndexes, int[] secondFieldIndexes, org.apache.flink.api.common.operators.base.CrossOperatorBase.CrossHint hint)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected CrossOperator.CrossProjection<I1,I2>projectFirst(int... firstFieldIndexes)Continues a ProjectCross transformation and adds fields of the first cross input.protected CrossOperator.CrossProjection<I1,I2>projectSecond(int... secondFieldIndexes)Continues a ProjectCross transformation and adds fields of the second cross input.<T0> CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple1<T0>>projectTuple1()Projects a pair of crossed elements to aTuplewith the previously selected fields.<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9>
CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple10<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9>>projectTuple10()Projects a pair of crossed elements to aTuplewith the previously selected fields.<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10>
CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple11<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10>>projectTuple11()Projects a pair of crossed elements to aTuplewith the previously selected fields.<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11>
CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple12<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11>>projectTuple12()Projects a pair of crossed elements to aTuplewith the previously selected fields.<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12>
CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple13<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12>>projectTuple13()Projects a pair of crossed elements to aTuplewith the previously selected fields.<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13>
CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple14<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13>>projectTuple14()Projects a pair of crossed elements to aTuplewith the previously selected fields.<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14>
CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple15<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14>>projectTuple15()Projects a pair of crossed elements to aTuplewith the previously selected fields.<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15>
CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple16<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15>>projectTuple16()Projects a pair of crossed elements to aTuplewith the previously selected fields.<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16>
CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple17<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16>>projectTuple17()Projects a pair of crossed elements to aTuplewith the previously selected fields.<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17>
CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple18<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17>>projectTuple18()Projects a pair of crossed elements to aTuplewith the previously selected fields.<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18>
CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple19<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18>>projectTuple19()Projects a pair of crossed elements to aTuplewith the previously selected fields.<T0,T1>
CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple2<T0,T1>>projectTuple2()Projects a pair of crossed elements to aTuplewith the previously selected fields.<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19>
CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple20<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19>>projectTuple20()Projects a pair of crossed elements to aTuplewith the previously selected fields.<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20>
CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple21<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20>>projectTuple21()Projects a pair of crossed elements to aTuplewith the previously selected fields.<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21>
CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple22<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21>>projectTuple22()Projects a pair of crossed elements to aTuplewith the previously selected fields.<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22>
CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple23<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22>>projectTuple23()Projects a pair of crossed elements to aTuplewith the previously selected fields.<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22,T23>
CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple24<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22,T23>>projectTuple24()Projects a pair of crossed elements to aTuplewith the previously selected fields.<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22,T23,T24>
CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple25<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22,T23,T24>>projectTuple25()Projects a pair of crossed elements to aTuplewith the previously selected fields.<T0,T1,T2>
CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple3<T0,T1,T2>>projectTuple3()Projects a pair of crossed elements to aTuplewith the previously selected fields.<T0,T1,T2,T3>
CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple4<T0,T1,T2,T3>>projectTuple4()Projects a pair of crossed elements to aTuplewith the previously selected fields.<T0,T1,T2,T3,T4>
CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple5<T0,T1,T2,T3,T4>>projectTuple5()Projects a pair of crossed elements to aTuplewith the previously selected fields.<T0,T1,T2,T3,T4,T5>
CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple6<T0,T1,T2,T3,T4,T5>>projectTuple6()Projects a pair of crossed elements to aTuplewith the previously selected fields.<T0,T1,T2,T3,T4,T5,T6>
CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple7<T0,T1,T2,T3,T4,T5,T6>>projectTuple7()Projects a pair of crossed elements to aTuplewith the previously selected fields.<T0,T1,T2,T3,T4,T5,T6,T7>
CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple8<T0,T1,T2,T3,T4,T5,T6,T7>>projectTuple8()Projects a pair of crossed elements to aTuplewith the previously selected fields.<T0,T1,T2,T3,T4,T5,T6,T7,T8>
CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple9<T0,T1,T2,T3,T4,T5,T6,T7,T8>>projectTuple9()Projects a pair of crossed elements to aTuplewith the previously selected fields.<OUT extends org.apache.flink.api.java.tuple.Tuple>
CrossOperator.ProjectCross<I1,I2,OUT>projectTupleX()Chooses a projectTupleX according to the length offieldIndexes.
-
-
-
Method Detail
-
projectFirst
protected CrossOperator.CrossProjection<I1,I2> projectFirst(int... firstFieldIndexes)
Continues a ProjectCross transformation and adds fields of the first cross input.If the first cross input is a
TupleDataSet, fields can be selected by their index. If the first cross input is not a Tuple DataSet, no parameters should be passed.Fields of the first and second input can be added by chaining the method calls of
projectFirst(int...)andprojectSecond(int...).- Parameters:
firstFieldIndexes- If the first input is a Tuple DataSet, the indexes of the selected fields. For a non-Tuple DataSet, do not provide parameters. The order of fields in the output tuple is defined by to the order of field indexes.- Returns:
- An extended CrossProjection.
- See Also:
Tuple,DataSet,CrossOperator.CrossProjection,CrossOperator.ProjectCross
-
projectSecond
protected CrossOperator.CrossProjection<I1,I2> projectSecond(int... secondFieldIndexes)
Continues a ProjectCross transformation and adds fields of the second cross input.If the second cross input is a
TupleDataSet, fields can be selected by their index. If the second cross input is not a Tuple DataSet, no parameters should be passed.Fields of the first and second input can be added by chaining the method calls of
projectFirst(int...)andprojectSecond(int...).- Parameters:
secondFieldIndexes- If the second input is a Tuple DataSet, the indexes of the selected fields. For a non-Tuple DataSet, do not provide parameters. The order of fields in the output tuple is defined by to the order of field indexes.- Returns:
- An extended CrossProjection.
- See Also:
Tuple,DataSet,CrossOperator.CrossProjection,CrossOperator.ProjectCross
-
projectTupleX
public <OUT extends org.apache.flink.api.java.tuple.Tuple> CrossOperator.ProjectCross<I1,I2,OUT> projectTupleX()
Chooses a projectTupleX according to the length offieldIndexes.- Returns:
- The projected DataSet.
-
projectTuple1
public <T0> CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple1<T0>> projectTuple1()
Projects a pair of crossed elements to aTuplewith the previously selected fields.- Returns:
- The projected data set.
- See Also:
Tuple,DataSet
-
projectTuple2
public <T0,T1> CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple2<T0,T1>> projectTuple2()
Projects a pair of crossed elements to aTuplewith the previously selected fields.- Returns:
- The projected data set.
- See Also:
Tuple,DataSet
-
projectTuple3
public <T0,T1,T2> CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple3<T0,T1,T2>> projectTuple3()
Projects a pair of crossed elements to aTuplewith the previously selected fields.- Returns:
- The projected data set.
- See Also:
Tuple,DataSet
-
projectTuple4
public <T0,T1,T2,T3> CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple4<T0,T1,T2,T3>> projectTuple4()
Projects a pair of crossed elements to aTuplewith the previously selected fields.- Returns:
- The projected data set.
- See Also:
Tuple,DataSet
-
projectTuple5
public <T0,T1,T2,T3,T4> CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple5<T0,T1,T2,T3,T4>> projectTuple5()
Projects a pair of crossed elements to aTuplewith the previously selected fields.- Returns:
- The projected data set.
- See Also:
Tuple,DataSet
-
projectTuple6
public <T0,T1,T2,T3,T4,T5> CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple6<T0,T1,T2,T3,T4,T5>> projectTuple6()
Projects a pair of crossed elements to aTuplewith the previously selected fields.- Returns:
- The projected data set.
- See Also:
Tuple,DataSet
-
projectTuple7
public <T0,T1,T2,T3,T4,T5,T6> CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple7<T0,T1,T2,T3,T4,T5,T6>> projectTuple7()
Projects a pair of crossed elements to aTuplewith the previously selected fields.- Returns:
- The projected data set.
- See Also:
Tuple,DataSet
-
projectTuple8
public <T0,T1,T2,T3,T4,T5,T6,T7> CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple8<T0,T1,T2,T3,T4,T5,T6,T7>> projectTuple8()
Projects a pair of crossed elements to aTuplewith the previously selected fields.- Returns:
- The projected data set.
- See Also:
Tuple,DataSet
-
projectTuple9
public <T0,T1,T2,T3,T4,T5,T6,T7,T8> CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple9<T0,T1,T2,T3,T4,T5,T6,T7,T8>> projectTuple9()
Projects a pair of crossed elements to aTuplewith the previously selected fields.- Returns:
- The projected data set.
- See Also:
Tuple,DataSet
-
projectTuple10
public <T0,T1,T2,T3,T4,T5,T6,T7,T8,T9> CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple10<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9>> projectTuple10()
Projects a pair of crossed elements to aTuplewith the previously selected fields.- Returns:
- The projected data set.
- See Also:
Tuple,DataSet
-
projectTuple11
public <T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10> CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple11<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10>> projectTuple11()
Projects a pair of crossed elements to aTuplewith the previously selected fields.- Returns:
- The projected data set.
- See Also:
Tuple,DataSet
-
projectTuple12
public <T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11> CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple12<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11>> projectTuple12()
Projects a pair of crossed elements to aTuplewith the previously selected fields.- Returns:
- The projected data set.
- See Also:
Tuple,DataSet
-
projectTuple13
public <T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12> CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple13<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12>> projectTuple13()
Projects a pair of crossed elements to aTuplewith the previously selected fields.- Returns:
- The projected data set.
- See Also:
Tuple,DataSet
-
projectTuple14
public <T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13> CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple14<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13>> projectTuple14()
Projects a pair of crossed elements to aTuplewith the previously selected fields.- Returns:
- The projected data set.
- See Also:
Tuple,DataSet
-
projectTuple15
public <T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14> CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple15<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14>> projectTuple15()
Projects a pair of crossed elements to aTuplewith the previously selected fields.- Returns:
- The projected data set.
- See Also:
Tuple,DataSet
-
projectTuple16
public <T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15> CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple16<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15>> projectTuple16()
Projects a pair of crossed elements to aTuplewith the previously selected fields.- Returns:
- The projected data set.
- See Also:
Tuple,DataSet
-
projectTuple17
public <T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16> CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple17<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16>> projectTuple17()
Projects a pair of crossed elements to aTuplewith the previously selected fields.- Returns:
- The projected data set.
- See Also:
Tuple,DataSet
-
projectTuple18
public <T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17> CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple18<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17>> projectTuple18()
Projects a pair of crossed elements to aTuplewith the previously selected fields.- Returns:
- The projected data set.
- See Also:
Tuple,DataSet
-
projectTuple19
public <T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18> CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple19<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18>> projectTuple19()
Projects a pair of crossed elements to aTuplewith the previously selected fields.- Returns:
- The projected data set.
- See Also:
Tuple,DataSet
-
projectTuple20
public <T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19> CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple20<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19>> projectTuple20()
Projects a pair of crossed elements to aTuplewith the previously selected fields.- Returns:
- The projected data set.
- See Also:
Tuple,DataSet
-
projectTuple21
public <T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20> CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple21<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20>> projectTuple21()
Projects a pair of crossed elements to aTuplewith the previously selected fields.- Returns:
- The projected data set.
- See Also:
Tuple,DataSet
-
projectTuple22
public <T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21> CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple22<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21>> projectTuple22()
Projects a pair of crossed elements to aTuplewith the previously selected fields.- Returns:
- The projected data set.
- See Also:
Tuple,DataSet
-
projectTuple23
public <T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22> CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple23<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22>> projectTuple23()
Projects a pair of crossed elements to aTuplewith the previously selected fields.- Returns:
- The projected data set.
- See Also:
Tuple,DataSet
-
projectTuple24
public <T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22,T23> CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple24<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22,T23>> projectTuple24()
Projects a pair of crossed elements to aTuplewith the previously selected fields.- Returns:
- The projected data set.
- See Also:
Tuple,DataSet
-
projectTuple25
public <T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22,T23,T24> CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple25<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22,T23,T24>> projectTuple25()
Projects a pair of crossed elements to aTuplewith the previously selected fields.- Returns:
- The projected data set.
- See Also:
Tuple,DataSet
-
-