Uses of Class
org.apache.flink.api.common.operators.BinaryOperatorInformation
-
Packages that use BinaryOperatorInformation Package Description org.apache.flink.api.common.operators org.apache.flink.api.common.operators.base -
-
Uses of BinaryOperatorInformation in org.apache.flink.api.common.operators
Methods in org.apache.flink.api.common.operators that return BinaryOperatorInformation Modifier and Type Method Description BinaryOperatorInformation<IN1,IN2,OUT>DualInputOperator. getOperatorInfo()Gets the information about the operators input/output types.Constructors in org.apache.flink.api.common.operators with parameters of type BinaryOperatorInformation Constructor Description DualInputOperator(UserCodeWrapper<FT> stub, BinaryOperatorInformation<IN1,IN2,OUT> operatorInfo, int[] keyPositions1, int[] keyPositions2, String name)Creates a new abstract dual-input operator with the given name wrapping the given user function.DualInputOperator(UserCodeWrapper<FT> stub, BinaryOperatorInformation<IN1,IN2,OUT> operatorInfo, String name)Creates a new abstract dual-input Pact with the given name wrapping the given user function.Union(BinaryOperatorInformation<T,T,T> operatorInfo, String unionLocationName)Creates a new Union operator. -
Uses of BinaryOperatorInformation in org.apache.flink.api.common.operators.base
Constructors in org.apache.flink.api.common.operators.base with parameters of type BinaryOperatorInformation Constructor Description CoGroupOperatorBase(FT udf, BinaryOperatorInformation<IN1,IN2,OUT> operatorInfo, int[] keyPositions1, int[] keyPositions2, String name)CoGroupOperatorBase(Class<? extends FT> udf, BinaryOperatorInformation<IN1,IN2,OUT> operatorInfo, int[] keyPositions1, int[] keyPositions2, String name)CoGroupOperatorBase(UserCodeWrapper<FT> udf, BinaryOperatorInformation<IN1,IN2,OUT> operatorInfo, int[] keyPositions1, int[] keyPositions2, String name)CoGroupRawOperatorBase(FT udf, BinaryOperatorInformation<IN1,IN2,OUT> operatorInfo, int[] keyPositions1, int[] keyPositions2, String name)CoGroupRawOperatorBase(Class<? extends FT> udf, BinaryOperatorInformation<IN1,IN2,OUT> operatorInfo, int[] keyPositions1, int[] keyPositions2, String name)CoGroupRawOperatorBase(UserCodeWrapper<FT> udf, BinaryOperatorInformation<IN1,IN2,OUT> operatorInfo, int[] keyPositions1, int[] keyPositions2, String name)CrossOperatorBase(FT udf, BinaryOperatorInformation<IN1,IN2,OUT> operatorInfo, String name)CrossOperatorBase(Class<? extends FT> udf, BinaryOperatorInformation<IN1,IN2,OUT> operatorInfo, String name)CrossOperatorBase(UserCodeWrapper<FT> udf, BinaryOperatorInformation<IN1,IN2,OUT> operatorInfo, String name)DeltaIterationBase(BinaryOperatorInformation<ST,WT,ST> operatorInfo, int keyPosition)DeltaIterationBase(BinaryOperatorInformation<ST,WT,ST> operatorInfo, int[] keyPositions)DeltaIterationBase(BinaryOperatorInformation<ST,WT,ST> operatorInfo, int[] keyPositions, String name)DeltaIterationBase(BinaryOperatorInformation<ST,WT,ST> operatorInfo, int keyPosition, String name)InnerJoinOperatorBase(FT udf, BinaryOperatorInformation<IN1,IN2,OUT> operatorInfo, int[] keyPositions1, int[] keyPositions2, String name)InnerJoinOperatorBase(Class<? extends FT> udf, BinaryOperatorInformation<IN1,IN2,OUT> operatorInfo, int[] keyPositions1, int[] keyPositions2, String name)InnerJoinOperatorBase(UserCodeWrapper<FT> udf, BinaryOperatorInformation<IN1,IN2,OUT> operatorInfo, int[] keyPositions1, int[] keyPositions2, String name)JoinOperatorBase(FT udf, BinaryOperatorInformation<IN1,IN2,OUT> operatorInfo, int[] keyPositions1, int[] keyPositions2, String name)JoinOperatorBase(Class<? extends FT> udf, BinaryOperatorInformation<IN1,IN2,OUT> operatorInfo, int[] keyPositions1, int[] keyPositions2, String name)JoinOperatorBase(UserCodeWrapper<FT> udf, BinaryOperatorInformation<IN1,IN2,OUT> operatorInfo, int[] keyPositions1, int[] keyPositions2, String name)OuterJoinOperatorBase(FT udf, BinaryOperatorInformation<IN1,IN2,OUT> operatorInfo, int[] keyPositions1, int[] keyPositions2, String name, OuterJoinOperatorBase.OuterJoinType outerJoinType)OuterJoinOperatorBase(Class<? extends FT> udf, BinaryOperatorInformation<IN1,IN2,OUT> operatorInfo, int[] keyPositions1, int[] keyPositions2, String name, OuterJoinOperatorBase.OuterJoinType outerJoinType)OuterJoinOperatorBase(UserCodeWrapper<FT> udf, BinaryOperatorInformation<IN1,IN2,OUT> operatorInfo, int[] keyPositions1, int[] keyPositions2, String name, OuterJoinOperatorBase.OuterJoinType outerJoinType)
-