Package org.apache.wayang.iejoin.operators

Class IESelfJoinOperator<Type0 extends Comparable<Type0>,Type1 extends Comparable<Type1>,Input>

java.lang.Object

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

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

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

All Implemented Interfaces:

Serializable, ActualOperator, ElementaryOperator, Operator

Direct Known Subclasses:

JavaIESelfJoinOperator, SparkIESelfJoinOperator

public class IESelfJoinOperator<Type0 extends Comparable<Type0>,Type1 extends Comparable<Type1>,Input>
extends UnaryToUnaryOperator<Input,Tuple2<Input,Input>>

This operator applies inequality self 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 final IEJoinMasterOperator.JoinCondition	cond0
protected final IEJoinMasterOperator.JoinCondition	cond1
protected boolean	equalReverse
protected final TransformationDescriptor<Input,Type0>	get0Pivot
protected final TransformationDescriptor<Input,Type1>	get0Ref
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
IESelfJoinOperator(Class<Input> inputTypeClass, TransformationDescriptor<Input,Type0> get0Pivot, IEJoinMasterOperator.JoinCondition cond0, TransformationDescriptor<Input,Type1> get0Ref, IEJoinMasterOperator.JoinCondition cond1)
IESelfJoinOperator(DataSetType<Input> inputType, TransformationDescriptor<Input,Type0> get0Pivot, IEJoinMasterOperator.JoinCondition cond0, TransformationDescriptor<Input,Type1> get0Ref, 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()

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

getInput, getInputType, getOutput, 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, isConversion, isElementary, isExecutionOperator, isFeedbackInput, isFeedforwardOutput, isLoopHead, isLoopSubplan, isOwnerOf, isReading, isSink, isSource, isSubplan, isSupportingBroadcastInputs, isUnconnected, propagateInputCardinality, propagateOutputCardinality, propagateOutputCardinality, replaceWith, setContainer, setEpoch, setInput, setName, setOutput

Field Details

get0Pivot

protected final TransformationDescriptor<Input,Type0 extends Comparable<Type0>> get0Pivot

cond0

protected final IEJoinMasterOperator.JoinCondition cond0

get0Ref

protected final TransformationDescriptor<Input,Type1 extends Comparable<Type1>> get0Ref

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 Details

IESelfJoinOperator

public IESelfJoinOperator(Class<Input> inputTypeClass,
 TransformationDescriptor<Input,Type0> get0Pivot,
 IEJoinMasterOperator.JoinCondition cond0,
 TransformationDescriptor<Input,Type1> get0Ref,
 IEJoinMasterOperator.JoinCondition cond1)

IESelfJoinOperator

public IESelfJoinOperator(DataSetType<Input> inputType,
 TransformationDescriptor<Input,Type0> get0Pivot,
 IEJoinMasterOperator.JoinCondition cond0,
 TransformationDescriptor<Input,Type1> get0Ref,
 IEJoinMasterOperator.JoinCondition cond1)

Method Details

assignSortOrders

public void assignSortOrders()

getGet0Pivot

public TransformationDescriptor<Input,Type0> getGet0Pivot()

getGet0Ref

public TransformationDescriptor<Input,Type1> getGet0Ref()

getCond0

public IEJoinMasterOperator.JoinCondition getCond0()

getCond1

public IEJoinMasterOperator.JoinCondition getCond1()