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

Class OuterJoinOperatorBase<IN1,IN2,OUT,FT extends FlatJoinFunction<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.JoinOperatorBase<IN1,IN2,OUT,FT>

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

All Implemented Interfaces:

Visitable<Operator<?>>

@Internal
public class OuterJoinOperatorBase<IN1,IN2,OUT,FT extends FlatJoinFunction<IN1,IN2,OUT>>
extends JoinOperatorBase<IN1,IN2,OUT,FT>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	OuterJoinOperatorBase.OuterJoinType

Nested classes/interfaces inherited from class org.apache.flink.api.common.operators.base.JoinOperatorBase

JoinOperatorBase.JoinHint

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	Description
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)

Method Summary

Modifier and Type	Method	Description
protected List<OUT>	executeOnCollections(List<IN1> leftInput, List<IN2> rightInput, RuntimeContext runtimeContext, ExecutionConfig executionConfig)
OuterJoinOperatorBase.OuterJoinType	getOuterJoinType()
void	setOuterJoinType(OuterJoinOperatorBase.OuterJoinType outerJoinType)

Methods inherited from class org.apache.flink.api.common.operators.base.JoinOperatorBase

getCustomPartitioner, getJoinHint, setCustomPartitioner, setJoinHint

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

OuterJoinOperatorBase

public OuterJoinOperatorBase(UserCodeWrapper<FT> udf,
                             BinaryOperatorInformation<IN1,IN2,OUT> operatorInfo,
                             int[] keyPositions1,
                             int[] keyPositions2,
                             String name,
                             OuterJoinOperatorBase.OuterJoinType outerJoinType)

OuterJoinOperatorBase

public OuterJoinOperatorBase(FT udf,
                             BinaryOperatorInformation<IN1,IN2,OUT> operatorInfo,
                             int[] keyPositions1,
                             int[] keyPositions2,
                             String name,
                             OuterJoinOperatorBase.OuterJoinType outerJoinType)

OuterJoinOperatorBase

public OuterJoinOperatorBase(Class<? extends FT> udf,
                             BinaryOperatorInformation<IN1,IN2,OUT> operatorInfo,
                             int[] keyPositions1,
                             int[] keyPositions2,
                             String name,
                             OuterJoinOperatorBase.OuterJoinType outerJoinType)

Method Detail

setOuterJoinType

public void setOuterJoinType(OuterJoinOperatorBase.OuterJoinType outerJoinType)

getOuterJoinType

public OuterJoinOperatorBase.OuterJoinType getOuterJoinType()

executeOnCollections

protected List<OUT> executeOnCollections(List<IN1> leftInput,
                                         List<IN2> rightInput,
                                         RuntimeContext runtimeContext,
                                         ExecutionConfig executionConfig)
                                  throws Exception

Specified by:

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

Throws:

Exception