Package org.apache.flink.optimizer.operators

Class AbstractSortMergeJoinDescriptor

java.lang.Object

org.apache.flink.optimizer.operators.OperatorDescriptorDual

org.apache.flink.optimizer.operators.AbstractJoinDescriptor

org.apache.flink.optimizer.operators.AbstractSortMergeJoinDescriptor

All Implemented Interfaces:

AbstractOperatorDescriptor

Direct Known Subclasses:

SortMergeFullOuterJoinDescriptor, SortMergeInnerJoinDescriptor, SortMergeLeftOuterJoinDescriptor, SortMergeRightOuterJoinDescriptor

public abstract class AbstractSortMergeJoinDescriptor
extends AbstractJoinDescriptor

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.optimizer.operators.OperatorDescriptorDual

OperatorDescriptorDual.GlobalPropertiesPair, OperatorDescriptorDual.LocalPropertiesPair

Field Summary

Fields inherited from class org.apache.flink.optimizer.operators.OperatorDescriptorDual

keys1, keys2

Constructor Summary

Constructors

Constructor	Description
AbstractSortMergeJoinDescriptor(org.apache.flink.api.common.operators.util.FieldList keys1, org.apache.flink.api.common.operators.util.FieldList keys2)
AbstractSortMergeJoinDescriptor(org.apache.flink.api.common.operators.util.FieldList keys1, org.apache.flink.api.common.operators.util.FieldList keys2, boolean broadcastFirstAllowed, boolean broadcastSecondAllowed, boolean repartitionAllowed)

Method Summary

Modifier and Type	Method	Description
boolean	areCoFulfilled(RequestedLocalProperties requested1, RequestedLocalProperties requested2, LocalProperties produced1, LocalProperties produced2)
LocalProperties	computeLocalProperties(LocalProperties in1, LocalProperties in2)
protected List<OperatorDescriptorDual.LocalPropertiesPair>	createPossibleLocalProperties()
protected abstract String	getNodeName()
DualInputPlanNode	instantiate(Channel in1, Channel in2, TwoInputNode node)

Methods inherited from class org.apache.flink.optimizer.operators.AbstractJoinDescriptor

areCompatible, computeGlobalProperties, createPossibleGlobalProperties, setCustomPartitioner

Methods inherited from class org.apache.flink.optimizer.operators.OperatorDescriptorDual

checkEquivalentFieldPositionsInKeyFields, checkEquivalentFieldPositionsInKeyFields, checkSameOrdering, checkSameOrdering, getPossibleGlobalProperties, getPossibleLocalProperties

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.optimizer.operators.AbstractOperatorDescriptor

getStrategy

Constructor Detail

AbstractSortMergeJoinDescriptor

public AbstractSortMergeJoinDescriptor(org.apache.flink.api.common.operators.util.FieldList keys1,
                                       org.apache.flink.api.common.operators.util.FieldList keys2)

AbstractSortMergeJoinDescriptor

public AbstractSortMergeJoinDescriptor(org.apache.flink.api.common.operators.util.FieldList keys1,
                                       org.apache.flink.api.common.operators.util.FieldList keys2,
                                       boolean broadcastFirstAllowed,
                                       boolean broadcastSecondAllowed,
                                       boolean repartitionAllowed)

Method Detail

createPossibleLocalProperties

protected List<OperatorDescriptorDual.LocalPropertiesPair> createPossibleLocalProperties()

Specified by:

createPossibleLocalProperties in class OperatorDescriptorDual

areCoFulfilled

public boolean areCoFulfilled(RequestedLocalProperties requested1,
                              RequestedLocalProperties requested2,
                              LocalProperties produced1,
                              LocalProperties produced2)

Specified by:

areCoFulfilled in class OperatorDescriptorDual

instantiate

public DualInputPlanNode instantiate(Channel in1,
                                     Channel in2,
                                     TwoInputNode node)

Specified by:

instantiate in class OperatorDescriptorDual

computeLocalProperties

public LocalProperties computeLocalProperties(LocalProperties in1,
                                              LocalProperties in2)

Specified by:

computeLocalProperties in class OperatorDescriptorDual

getNodeName

protected abstract String getNodeName()