Package | Description |
---|---|
org.apache.flink.api.java.operators |
Modifier and Type | Method and Description |
---|---|
<OUT extends Tuple> |
CrossOperator.DefaultCross.projectFirst(int... firstFieldIndexes)
Initiates a ProjectCross transformation and projects the first cross input.
|
<OUT extends Tuple> |
CrossOperator.ProjectCross.projectFirst(int... firstFieldIndexes)
Continues a ProjectCross transformation and adds fields of the first cross input to the projection.
|
<OUT extends Tuple> |
CrossOperator.DefaultCross.projectSecond(int... secondFieldIndexes)
Initiates a ProjectCross transformation and projects the second cross input.
|
<OUT extends Tuple> |
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,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.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.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.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.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.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.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.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.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.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.CrossProjection.projectTuple19()
Projects a pair of crossed elements to a
Tuple with the previously selected fields. |
<T0,T1> CrossOperator.ProjectCross<I1,I2,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.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.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.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.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.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.CrossProjection.projectTuple25()
Projects a pair of crossed elements to a
Tuple with the previously selected fields. |
<T0,T1,T2> CrossOperator.ProjectCross<I1,I2,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.CrossProjection.projectTuple4()
Projects a pair of crossed elements to a
Tuple with the previously selected fields. |
<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.CrossProjection.projectTuple6()
Projects a pair of crossed elements to a
Tuple with the previously selected fields. |
<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.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.CrossProjection.projectTuple9()
Projects a pair of crossed elements to a
Tuple with the previously selected fields. |
<OUT extends Tuple> |
CrossOperator.CrossProjection.projectTupleX()
Chooses a projectTupleX according to the length of
CrossOperator.CrossProjection.fieldIndexes . |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.