<OUT extends org.apache.flink.api.java.tuple.Tuple> CrossOperator.ProjectCross<I1,I2,OUT> |
CrossOperator.DefaultCross.projectFirst(int... firstFieldIndexes) |
Initiates a ProjectCross transformation and projects the first cross input.
|
<OUT extends org.apache.flink.api.java.tuple.Tuple> CrossOperator.ProjectCross<I1,I2,OUT> |
CrossOperator.ProjectCross.projectFirst(int... firstFieldIndexes) |
Continues a ProjectCross transformation and adds fields of the first cross input to the
projection.
|
<OUT extends org.apache.flink.api.java.tuple.Tuple> CrossOperator.ProjectCross<I1,I2,OUT> |
CrossOperator.DefaultCross.projectSecond(int... secondFieldIndexes) |
Initiates a ProjectCross transformation and projects the second cross input.
|
<OUT extends org.apache.flink.api.java.tuple.Tuple> CrossOperator.ProjectCross<I1,I2,OUT> |
CrossOperator.ProjectCross.projectSecond(int... secondFieldIndexes) |
Continues a ProjectCross transformation and adds fields of the second cross input to the
projection.
|
<T0> CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple1<T0>> |
CrossOperator.CrossProjection.projectTuple1() |
Projects a pair of crossed elements to a Tuple with 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>> |
CrossOperator.CrossProjection.projectTuple10() |
Projects a pair of crossed elements to a Tuple with 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>> |
CrossOperator.CrossProjection.projectTuple11() |
Projects a pair of crossed elements to a Tuple with 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>> |
CrossOperator.CrossProjection.projectTuple12() |
Projects a pair of crossed elements to a Tuple with 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>> |
CrossOperator.CrossProjection.projectTuple13() |
Projects a pair of crossed elements to a Tuple with 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>> |
CrossOperator.CrossProjection.projectTuple14() |
Projects a pair of crossed elements to a Tuple with 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>> |
CrossOperator.CrossProjection.projectTuple15() |
Projects a pair of crossed elements to a Tuple with 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>> |
CrossOperator.CrossProjection.projectTuple16() |
Projects a pair of crossed elements to a Tuple with 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>> |
CrossOperator.CrossProjection.projectTuple17() |
Projects a pair of crossed elements to a Tuple with 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>> |
CrossOperator.CrossProjection.projectTuple18() |
Projects a pair of crossed elements to a Tuple with 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>> |
CrossOperator.CrossProjection.projectTuple19() |
Projects a pair of crossed elements to a Tuple with the previously selected
fields.
|
<T0,T1> CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple2<T0,T1>> |
CrossOperator.CrossProjection.projectTuple2() |
Projects a pair of crossed elements to a Tuple with 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>> |
CrossOperator.CrossProjection.projectTuple20() |
Projects a pair of crossed elements to a Tuple with 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>> |
CrossOperator.CrossProjection.projectTuple21() |
Projects a pair of crossed elements to a Tuple with 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>> |
CrossOperator.CrossProjection.projectTuple22() |
Projects a pair of crossed elements to a Tuple with 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>> |
CrossOperator.CrossProjection.projectTuple23() |
Projects a pair of crossed elements to a Tuple with 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>> |
CrossOperator.CrossProjection.projectTuple24() |
Projects a pair of crossed elements to a Tuple with 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>> |
CrossOperator.CrossProjection.projectTuple25() |
Projects a pair of crossed elements to a Tuple with the previously selected
fields.
|
<T0,T1,T2> CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple3<T0,T1,T2>> |
CrossOperator.CrossProjection.projectTuple3() |
Projects a pair of crossed elements to a Tuple with the previously selected
fields.
|
<T0,T1,T2,T3> CrossOperator.ProjectCross<I1,I2,org.apache.flink.api.java.tuple.Tuple4<T0,T1,T2,T3>> |
CrossOperator.CrossProjection.projectTuple4() |
Projects a pair of crossed elements to a Tuple with 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>> |
CrossOperator.CrossProjection.projectTuple5() |
Projects a pair of crossed elements to a Tuple with 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>> |
CrossOperator.CrossProjection.projectTuple6() |
Projects a pair of crossed elements to a Tuple with 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>> |
CrossOperator.CrossProjection.projectTuple7() |
Projects a pair of crossed elements to a Tuple with 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>> |
CrossOperator.CrossProjection.projectTuple8() |
Projects a pair of crossed elements to a Tuple with 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>> |
CrossOperator.CrossProjection.projectTuple9() |
Projects a pair of crossed elements to a Tuple with the previously selected
fields.
|
<OUT extends org.apache.flink.api.java.tuple.Tuple> CrossOperator.ProjectCross<I1,I2,OUT> |
CrossOperator.CrossProjection.projectTupleX() |
Chooses a projectTupleX according to the length of CrossOperator.CrossProjection.fieldIndexes.
|