Class CrossOperator.ProjectCrossFunction<T1,T2,R extends org.apache.flink.api.java.tuple.Tuple>
- java.lang.Object
-
- org.apache.flink.api.java.operators.CrossOperator.ProjectCrossFunction<T1,T2,R>
-
- Type Parameters:
T1-T2-R-
- All Implemented Interfaces:
Serializable,org.apache.flink.api.common.functions.CrossFunction<T1,T2,R>,org.apache.flink.api.common.functions.Function
- Enclosing class:
- CrossOperator<I1,I2,OUT>
@Internal public static final class CrossOperator.ProjectCrossFunction<T1,T2,R extends org.apache.flink.api.java.tuple.Tuple> extends Object implements org.apache.flink.api.common.functions.CrossFunction<T1,T2,R>
- See Also:
CrossOperator.ProjectCross, Serialized Form
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Rcross(T1 in1, T2 in2)protected int[]getFields()protected boolean[]getIsFromFirst()
-