org.apache.flink.optimizer.operators

Class OperatorDescriptorDual

java.lang.Object

org.apache.flink.optimizer.operators.OperatorDescriptorDual

All Implemented Interfaces:

AbstractOperatorDescriptor

Direct Known Subclasses:

AbstractJoinDescriptor, BinaryUnionOpDescriptor, CartesianProductDescriptor, CoGroupDescriptor, CoGroupRawDescriptor, UtilSinkJoinOpDescriptor

public abstract class OperatorDescriptorDual
extends Object
implements AbstractOperatorDescriptor

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	OperatorDescriptorDual.GlobalPropertiesPair
static class	OperatorDescriptorDual.LocalPropertiesPair

Field Summary

Fields

Modifier and Type	Field and Description
protected FieldList	keys1
protected FieldList	keys2

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	OperatorDescriptorDual()
protected	OperatorDescriptorDual(FieldList keys1, FieldList keys2)

Method Summary

Modifier and Type	Method and Description
abstract boolean	areCoFulfilled(RequestedLocalProperties requested1, RequestedLocalProperties requested2, LocalProperties produced1, LocalProperties produced2)
abstract boolean	areCompatible(RequestedGlobalProperties requested1, RequestedGlobalProperties requested2, GlobalProperties produced1, GlobalProperties produced2)
protected boolean	checkCompatibilityBasedOnDiversePartitioningProperty(GlobalProperties produced1, GlobalProperties produced2)
protected boolean	checkEquivalentFieldPositionsInKeyFields(FieldList fields1, FieldList fields2)
protected boolean	checkEquivalentFieldPositionsInKeyFields(FieldList fields1, FieldList fields2, int numRelevantFields)
protected boolean	checkSameOrdering(GlobalProperties produced1, GlobalProperties produced2, int numRelevantFields)
protected boolean	checkSameOrdering(LocalProperties produced1, LocalProperties produced2, int numRelevantFields)
abstract GlobalProperties	computeGlobalProperties(GlobalProperties in1, GlobalProperties in2)
abstract LocalProperties	computeLocalProperties(LocalProperties in1, LocalProperties in2)
protected abstract List<OperatorDescriptorDual.GlobalPropertiesPair>	createPossibleGlobalProperties()
protected abstract List<OperatorDescriptorDual.LocalPropertiesPair>	createPossibleLocalProperties()
List<OperatorDescriptorDual.GlobalPropertiesPair>	getPossibleGlobalProperties()
List<OperatorDescriptorDual.LocalPropertiesPair>	getPossibleLocalProperties()
abstract DualInputPlanNode	instantiate(Channel in1, Channel in2, TwoInputNode node)

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

Field Detail

keys1

protected final FieldList keys1

keys2

protected final FieldList keys2

Constructor Detail

OperatorDescriptorDual

protected OperatorDescriptorDual()

OperatorDescriptorDual

protected OperatorDescriptorDual(FieldList keys1,
                                 FieldList keys2)

Method Detail

getPossibleGlobalProperties

public List<OperatorDescriptorDual.GlobalPropertiesPair> getPossibleGlobalProperties()

getPossibleLocalProperties

public List<OperatorDescriptorDual.LocalPropertiesPair> getPossibleLocalProperties()

createPossibleGlobalProperties

protected abstract List<OperatorDescriptorDual.GlobalPropertiesPair> createPossibleGlobalProperties()

createPossibleLocalProperties

protected abstract List<OperatorDescriptorDual.LocalPropertiesPair> createPossibleLocalProperties()

areCompatible

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

areCoFulfilled

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

instantiate

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

computeGlobalProperties

public abstract GlobalProperties computeGlobalProperties(GlobalProperties in1,
                                                         GlobalProperties in2)

computeLocalProperties

public abstract LocalProperties computeLocalProperties(LocalProperties in1,
                                                       LocalProperties in2)

checkCompatibilityBasedOnDiversePartitioningProperty

protected boolean checkCompatibilityBasedOnDiversePartitioningProperty(GlobalProperties produced1,
                                                                       GlobalProperties produced2)

checkEquivalentFieldPositionsInKeyFields

protected boolean checkEquivalentFieldPositionsInKeyFields(FieldList fields1,
                                                           FieldList fields2)

checkEquivalentFieldPositionsInKeyFields

protected boolean checkEquivalentFieldPositionsInKeyFields(FieldList fields1,
                                                           FieldList fields2,
                                                           int numRelevantFields)

checkSameOrdering

protected boolean checkSameOrdering(GlobalProperties produced1,
                                    GlobalProperties produced2,
                                    int numRelevantFields)

checkSameOrdering

protected boolean checkSameOrdering(LocalProperties produced1,
                                    LocalProperties produced2,
                                    int numRelevantFields)