Package org.apache.flink.optimizer.operators

Class AbstractJoinDescriptor

java.lang.Object

org.apache.flink.optimizer.operators.OperatorDescriptorDual

org.apache.flink.optimizer.operators.AbstractJoinDescriptor

All Implemented Interfaces:

AbstractOperatorDescriptor

Direct Known Subclasses:

AbstractSortMergeJoinDescriptor, HashFullOuterJoinBuildFirstDescriptor, HashFullOuterJoinBuildSecondDescriptor, HashJoinBuildFirstProperties, HashJoinBuildSecondProperties, HashLeftOuterJoinBuildFirstDescriptor, HashLeftOuterJoinBuildSecondDescriptor, HashRightOuterJoinBuildFirstDescriptor, HashRightOuterJoinBuildSecondDescriptor

public abstract class AbstractJoinDescriptor
extends OperatorDescriptorDual

Defines the possible global properties for a join.

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

Modifier	Constructor	Description
protected	AbstractJoinDescriptor(org.apache.flink.api.common.operators.util.FieldList keys1, org.apache.flink.api.common.operators.util.FieldList keys2)
protected	AbstractJoinDescriptor(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	areCompatible(RequestedGlobalProperties requested1, RequestedGlobalProperties requested2, GlobalProperties produced1, GlobalProperties produced2)
GlobalProperties	computeGlobalProperties(GlobalProperties in1, GlobalProperties in2)
protected List<OperatorDescriptorDual.GlobalPropertiesPair>	createPossibleGlobalProperties()
void	setCustomPartitioner(org.apache.flink.api.common.functions.Partitioner<?> partitioner)

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

areCoFulfilled, checkCompatibilityBasedOnDiversePartitioningProperty, checkEquivalentFieldPositionsInKeyFields, checkEquivalentFieldPositionsInKeyFields, checkSameOrdering, checkSameOrdering, computeLocalProperties, createPossibleLocalProperties, getPossibleGlobalProperties, getPossibleLocalProperties, instantiate

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

AbstractJoinDescriptor

protected AbstractJoinDescriptor(org.apache.flink.api.common.operators.util.FieldList keys1,
                                 org.apache.flink.api.common.operators.util.FieldList keys2)

AbstractJoinDescriptor

protected AbstractJoinDescriptor(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

setCustomPartitioner

public void setCustomPartitioner(org.apache.flink.api.common.functions.Partitioner<?> partitioner)

createPossibleGlobalProperties

protected List<OperatorDescriptorDual.GlobalPropertiesPair> createPossibleGlobalProperties()

Specified by:

createPossibleGlobalProperties in class OperatorDescriptorDual

areCompatible

public boolean areCompatible(RequestedGlobalProperties requested1,
                             RequestedGlobalProperties requested2,
                             GlobalProperties produced1,
                             GlobalProperties produced2)

Specified by:

areCompatible in class OperatorDescriptorDual

computeGlobalProperties

public GlobalProperties computeGlobalProperties(GlobalProperties in1,
                                                GlobalProperties in2)

Specified by:

computeGlobalProperties in class OperatorDescriptorDual