org.apache.flink.api.common.operators.base

Class CrossOperatorBase<IN1,IN2,OUT,FT extends CrossFunction<IN1,IN2,OUT>>

java.lang.Object

org.apache.flink.api.common.operators.Operator<OUT>

org.apache.flink.api.common.operators.AbstractUdfOperator<OUT,FT>

org.apache.flink.api.common.operators.DualInputOperator<IN1,IN2,OUT,FT>

org.apache.flink.api.common.operators.base.CrossOperatorBase<IN1,IN2,OUT,FT>

All Implemented Interfaces:

Visitable<Operator<?>>

@Internal
public class CrossOperatorBase<IN1,IN2,OUT,FT extends CrossFunction<IN1,IN2,OUT>>
extends DualInputOperator<IN1,IN2,OUT,FT>

See Also:

CrossFunction

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	CrossOperatorBase.CrossHint The cross hint tells the system which sizes to expect from the data sets
static interface	CrossOperatorBase.CrossWithLarge Marker interface to declare the second input as the larger one.
static interface	CrossOperatorBase.CrossWithSmall Marker interface to declare the second input as the smaller one.

Field Summary

Fields inherited from class org.apache.flink.api.common.operators.DualInputOperator

input1, input2

Fields inherited from class org.apache.flink.api.common.operators.AbstractUdfOperator

broadcastInputs, userFunction

Fields inherited from class org.apache.flink.api.common.operators.Operator

compilerHints, name, operatorInfo, parameters

Constructor Summary

Constructors

Constructor and Description
CrossOperatorBase(Class<? extends FT> udf, BinaryOperatorInformation<IN1,IN2,OUT> operatorInfo, String name)
CrossOperatorBase(FT udf, BinaryOperatorInformation<IN1,IN2,OUT> operatorInfo, String name)
CrossOperatorBase(UserCodeWrapper<FT> udf, BinaryOperatorInformation<IN1,IN2,OUT> operatorInfo, String name)

Method Summary

Modifier and Type	Method and Description
protected List<OUT>	executeOnCollections(List<IN1> inputData1, List<IN2> inputData2, RuntimeContext ctx, ExecutionConfig executionConfig)
CrossOperatorBase.CrossHint	getCrossHint()
void	setCrossHint(CrossOperatorBase.CrossHint hint)

Methods inherited from class org.apache.flink.api.common.operators.DualInputOperator

accept, addFirstInput, addFirstInputs, addSecondInput, addSecondInputs, clearFirstInput, clearSecondInput, getFirstInput, getKeyColumns, getNumberOfInputs, getOperatorInfo, getSecondInput, getSemanticProperties, setFirstInput, setFirstInput, setFirstInputs, setSecondInput, setSecondInput, setSecondInputs, setSemanticProperties

Methods inherited from class org.apache.flink.api.common.operators.AbstractUdfOperator

asArray, emptyClassArray, getBroadcastInputs, getUserCodeWrapper, setBroadcastVariable, setBroadcastVariables

Methods inherited from class org.apache.flink.api.common.operators.Operator

createUnionCascade, createUnionCascade, createUnionCascade, getCompilerHints, getMinResources, getName, getParallelism, getParameters, getPreferredResources, setName, setParallelism, setParameter, setParameter, setParameter, setResources, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

CrossOperatorBase

public CrossOperatorBase(UserCodeWrapper<FT> udf,
                         BinaryOperatorInformation<IN1,IN2,OUT> operatorInfo,
                         String name)

CrossOperatorBase

public CrossOperatorBase(FT udf,
                         BinaryOperatorInformation<IN1,IN2,OUT> operatorInfo,
                         String name)

CrossOperatorBase

public CrossOperatorBase(Class<? extends FT> udf,
                         BinaryOperatorInformation<IN1,IN2,OUT> operatorInfo,
                         String name)

Method Detail

setCrossHint

public void setCrossHint(CrossOperatorBase.CrossHint hint)

getCrossHint

public CrossOperatorBase.CrossHint getCrossHint()

executeOnCollections

protected List<OUT> executeOnCollections(List<IN1> inputData1,
                                         List<IN2> inputData2,
                                         RuntimeContext ctx,
                                         ExecutionConfig executionConfig)
                                  throws Exception

Specified by:

executeOnCollections in class DualInputOperator<IN1,IN2,OUT,FT extends CrossFunction<IN1,IN2,OUT>>

Throws:

Exception