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

Class JoinOperatorBase<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>

All Implemented Interfaces:

Visitable<Operator<?>>

Direct Known Subclasses:

InnerJoinOperatorBase, OuterJoinOperatorBase

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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	JoinOperatorBase.JoinHint An enumeration of hints, optionally usable to tell the system how exactly execute the join.

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
JoinOperatorBase(Class<? extends 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(UserCodeWrapper<FT> udf, BinaryOperatorInformation<IN1,IN2,OUT> operatorInfo, int[] keyPositions1, int[] keyPositions2, String name)

Method Summary

Modifier and Type	Method and Description
Partitioner<?>	getCustomPartitioner()
JoinOperatorBase.JoinHint	getJoinHint()
void	setCustomPartitioner(Partitioner<?> partitioner)
void	setJoinHint(JoinOperatorBase.JoinHint joinHint)

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

accept, addFirstInput, addFirstInputs, addSecondInput, addSecondInputs, clearFirstInput, clearSecondInput, executeOnCollections, 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

JoinOperatorBase

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

JoinOperatorBase

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

JoinOperatorBase

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

Method Detail

setJoinHint

public void setJoinHint(JoinOperatorBase.JoinHint joinHint)

getJoinHint

public JoinOperatorBase.JoinHint getJoinHint()

setCustomPartitioner

public void setCustomPartitioner(Partitioner<?> partitioner)

getCustomPartitioner

public Partitioner<?> getCustomPartitioner()