Uses of Class
org.apache.flink.api.java.operators.CrossOperator.CrossProjection
-
Packages that use CrossOperator.CrossProjection Package Description org.apache.flink.api.java.operators -
-
Uses of CrossOperator.CrossProjection in org.apache.flink.api.java.operators
Methods in org.apache.flink.api.java.operators that return CrossOperator.CrossProjection Modifier and Type Method Description protected CrossOperator.CrossProjection<I1,I2>CrossOperator.CrossProjection. projectFirst(int... firstFieldIndexes)Continues a ProjectCross transformation and adds fields of the first cross input.protected CrossOperator.CrossProjection<I1,I2>CrossOperator.CrossProjection. projectSecond(int... secondFieldIndexes)Continues a ProjectCross transformation and adds fields of the second cross input.Constructors in org.apache.flink.api.java.operators with parameters of type CrossOperator.CrossProjection Constructor Description ProjectCross(DataSet<I1> input1, DataSet<I2> input2, int[] fields, boolean[] isFromFirst, org.apache.flink.api.java.typeutils.TupleTypeInfo<OUT> returnType, CrossOperator.CrossProjection<I1,I2> crossProjection, org.apache.flink.api.common.operators.base.CrossOperatorBase.CrossHint hint)
-