Package org.apache.flink.optimizer.operators

Class SortMergeFullOuterJoinDescriptor

java.lang.Object

org.apache.flink.optimizer.operators.OperatorDescriptorDual

org.apache.flink.optimizer.operators.AbstractJoinDescriptor

org.apache.flink.optimizer.operators.AbstractSortMergeJoinDescriptor

org.apache.flink.optimizer.operators.SortMergeFullOuterJoinDescriptor

All Implemented Interfaces:

AbstractOperatorDescriptor

public class SortMergeFullOuterJoinDescriptor
extends AbstractSortMergeJoinDescriptor

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
SortMergeFullOuterJoinDescriptor(org.apache.flink.api.common.operators.util.FieldList keys1, org.apache.flink.api.common.operators.util.FieldList keys2)

Method Summary

Modifier and Type	Method	Description
protected String	getNodeName()
org.apache.flink.runtime.operators.DriverStrategy	getStrategy()	Gets the runtime strategy to be executed by this operator.

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

areCoFulfilled, computeLocalProperties, createPossibleLocalProperties, instantiate

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

areCompatible, computeGlobalProperties, createPossibleGlobalProperties, setCustomPartitioner

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

checkCompatibilityBasedOnDiversePartitioningProperty, checkEquivalentFieldPositionsInKeyFields, checkEquivalentFieldPositionsInKeyFields, checkSameOrdering, checkSameOrdering, getPossibleGlobalProperties, getPossibleLocalProperties

Methods inherited from class java.lang.Object

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

Constructor Detail

SortMergeFullOuterJoinDescriptor

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

Method Detail

getStrategy

public org.apache.flink.runtime.operators.DriverStrategy getStrategy()

Description copied from interface: AbstractOperatorDescriptor

Gets the runtime strategy to be executed by this operator.

Returns:

The runtime strategy.

getNodeName

protected String getNodeName()

Specified by:

getNodeName in class AbstractSortMergeJoinDescriptor