Package org.apache.wayang.iejoin.operators

Class IEJoinOperator<Type0,Type1,Input>

java.lang.Object

org.apache.wayang.core.plan.wayangplan.OperatorBase

org.apache.wayang.core.plan.wayangplan.BinaryToUnaryOperator<Input,Input,Tuple2<Input,Input>>

org.apache.wayang.iejoin.operators.IEJoinOperator<Type0,Type1,Input>

All Implemented Interfaces:

java.io.Serializable, ActualOperator, ElementaryOperator, Operator

Direct Known Subclasses:

JavaIEJoinOperator, SparkIEJoinOperator

public class IEJoinOperator<Type0,Type1,Input>
extends BinaryToUnaryOperator<Input,Input,Tuple2<Input,Input>>

This operator applies inequality join on elements of input datasets.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.wayang.core.plan.wayangplan.OperatorBase

OperatorBase.GsonSerializer

Field Summary

Fields

Modifier and Type	Field	Description
protected IEJoinMasterOperator.JoinCondition	cond0
protected IEJoinMasterOperator.JoinCondition	cond1
protected boolean	equalReverse
protected TransformationDescriptor<Input,Type0>	get0Pivot
protected TransformationDescriptor<Input,Type1>	get0Ref
protected TransformationDescriptor<Input,Type0>	get1Pivot
protected TransformationDescriptor<Input,Type1>	get1Ref
protected boolean	list1ASC
protected boolean	list1ASCSec
protected boolean	list2ASC
protected boolean	list2ASCSec

Fields inherited from class org.apache.wayang.core.plan.wayangplan.OperatorBase

inputSlots, outputSlots, STANDARD_OPERATOR_ARGS

Fields inherited from interface org.apache.wayang.core.plan.wayangplan.Operator

FIRST_EPOCH

Constructor Summary

Constructors

Constructor	Description
IEJoinOperator(java.lang.Class<Input> inputType0Class, java.lang.Class<Input> inputType1Class, TransformationDescriptor<Input,Type0> get0Pivot, TransformationDescriptor<Input,Type0> get1Pivot, IEJoinMasterOperator.JoinCondition cond0, TransformationDescriptor<Input,Type1> get0Ref, TransformationDescriptor<Input,Type1> get1Ref, IEJoinMasterOperator.JoinCondition cond1)
IEJoinOperator(DataSetType<Input> inputType0, DataSetType<Input> inputType1, TransformationDescriptor<Input,Type0> get0Pivot, TransformationDescriptor<Input,Type0> get1Pivot, IEJoinMasterOperator.JoinCondition cond0, TransformationDescriptor<Input,Type1> get0Ref, TransformationDescriptor<Input,Type1> get1Ref, IEJoinMasterOperator.JoinCondition cond1)

Method Summary

Modifier and Type	Method	Description
void	assignSortOrders()
IEJoinMasterOperator.JoinCondition	getCond0()
IEJoinMasterOperator.JoinCondition	getCond1()
TransformationDescriptor<Input,Type0>	getGet0Pivot()
TransformationDescriptor<Input,Type1>	getGet0Ref()
TransformationDescriptor<Input,Type0>	getGet1Pivot()
TransformationDescriptor<Input,Type1>	getGet1Ref()

Methods inherited from class org.apache.wayang.core.plan.wayangplan.BinaryToUnaryOperator

getInputType0, getInputType1, getOutputType

Methods inherited from class org.apache.wayang.core.plan.wayangplan.OperatorBase

accept, addBroadcastInput, addTargetPlatform, at, collectMappedInputSlots, collectMappedOutputSlots, copy, createCopy, getAllInputs, getAllOutputs, getCardinalityEstimator, getContainer, getEpoch, getName, getOriginal, getSimpleClassName, getTargetPlatforms, isAuxiliary, isSupportingBroadcastInputs, propagateInputCardinality, propagateOutputCardinality, setAuxiliary, setCardinalityEstimator, setContainer, setEpoch, setName, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.wayang.core.plan.wayangplan.ActualOperator

accept

Methods inherited from interface org.apache.wayang.core.plan.wayangplan.ElementaryOperator

createCardinalityEstimator, getCardinalityEstimator, isAuxiliary, setAuxiliary, setCardinalityEstimator

Methods inherited from interface org.apache.wayang.core.plan.wayangplan.Operator

addBroadcastInput, addTargetPlatform, broadcastTo, broadcastTo, collectMappedInputSlots, collectMappedOutputSlots, connectTo, connectTo, getAllInputs, getAllOutputs, getCardinalityPusher, getContainer, getEffectiveOccupant, getEffectiveOccupant, getEpoch, getEstimationContextProperties, getForwards, getInnermostLoop, getInput, getInput, getLoopStack, getName, getNumBroadcastInputs, getNumInputs, getNumOutputs, getNumRegularInputs, getOuterInputSlot, getOutermostInputSlot, getOutermostOutputSlots, getOutput, getOutput, getParent, getTargetPlatforms, isAlternative, isElementary, isExecutionOperator, isFeedbackInput, isFeedforwardOutput, isLoopHead, isLoopSubplan, isOwnerOf, isReading, isSink, isSource, isSubplan, isSupportingBroadcastInputs, isUnconnected, propagateInputCardinality, propagateOutputCardinality, propagateOutputCardinality, setContainer, setEpoch, setInput, setName, setOutput

Field Detail

get0Pivot

protected final TransformationDescriptor<Input,Type0> get0Pivot

get1Pivot

protected final TransformationDescriptor<Input,Type0> get1Pivot

cond0

protected final IEJoinMasterOperator.JoinCondition cond0

get0Ref

protected final TransformationDescriptor<Input,Type1> get0Ref

get1Ref

protected final TransformationDescriptor<Input,Type1> get1Ref

cond1

protected final IEJoinMasterOperator.JoinCondition cond1

list1ASC

protected boolean list1ASC

list1ASCSec

protected boolean list1ASCSec

list2ASC

protected boolean list2ASC

list2ASCSec

protected boolean list2ASCSec

equalReverse

protected boolean equalReverse

Constructor Detail

IEJoinOperator

public IEJoinOperator(java.lang.Class<Input> inputType0Class,
                      java.lang.Class<Input> inputType1Class,
                      TransformationDescriptor<Input,Type0> get0Pivot,
                      TransformationDescriptor<Input,Type0> get1Pivot,
                      IEJoinMasterOperator.JoinCondition cond0,
                      TransformationDescriptor<Input,Type1> get0Ref,
                      TransformationDescriptor<Input,Type1> get1Ref,
                      IEJoinMasterOperator.JoinCondition cond1)

IEJoinOperator

public IEJoinOperator(DataSetType<Input> inputType0,
                      DataSetType<Input> inputType1,
                      TransformationDescriptor<Input,Type0> get0Pivot,
                      TransformationDescriptor<Input,Type0> get1Pivot,
                      IEJoinMasterOperator.JoinCondition cond0,
                      TransformationDescriptor<Input,Type1> get0Ref,
                      TransformationDescriptor<Input,Type1> get1Ref,
                      IEJoinMasterOperator.JoinCondition cond1)

Method Detail

assignSortOrders

public void assignSortOrders()

getGet0Pivot

public TransformationDescriptor<Input,Type0> getGet0Pivot()

getGet0Ref

public TransformationDescriptor<Input,Type1> getGet0Ref()

getGet1Pivot

public TransformationDescriptor<Input,Type0> getGet1Pivot()

getGet1Ref

public TransformationDescriptor<Input,Type1> getGet1Ref()

getCond0

public IEJoinMasterOperator.JoinCondition getCond0()

getCond1

public IEJoinMasterOperator.JoinCondition getCond1()