Package org.apache.flink.optimizer.operators

Class CartesianProductDescriptor

java.lang.Object

org.apache.flink.optimizer.operators.OperatorDescriptorDual

org.apache.flink.optimizer.operators.CartesianProductDescriptor

All Implemented Interfaces:

AbstractOperatorDescriptor

Direct Known Subclasses:

CrossBlockOuterFirstDescriptor, CrossBlockOuterSecondDescriptor, CrossStreamOuterFirstDescriptor, CrossStreamOuterSecondDescriptor

public abstract class CartesianProductDescriptor
extends OperatorDescriptorDual

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	CartesianProductDescriptor(boolean allowBroadcastFirst, boolean allowBroadcastSecond)

Method Summary

Modifier and Type	Method	Description
boolean	areCoFulfilled(RequestedLocalProperties requested1, RequestedLocalProperties requested2, LocalProperties produced1, LocalProperties produced2)
boolean	areCompatible(RequestedGlobalProperties requested1, RequestedGlobalProperties requested2, GlobalProperties produced1, GlobalProperties produced2)
GlobalProperties	computeGlobalProperties(GlobalProperties in1, GlobalProperties in2)
protected List<OperatorDescriptorDual.GlobalPropertiesPair>	createPossibleGlobalProperties()
protected List<OperatorDescriptorDual.LocalPropertiesPair>	createPossibleLocalProperties()
DualInputPlanNode	instantiate(Channel in1, Channel in2, TwoInputNode node)

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

checkCompatibilityBasedOnDiversePartitioningProperty, checkEquivalentFieldPositionsInKeyFields, checkEquivalentFieldPositionsInKeyFields, checkSameOrdering, checkSameOrdering, computeLocalProperties, 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

CartesianProductDescriptor

protected CartesianProductDescriptor(boolean allowBroadcastFirst,
                                     boolean allowBroadcastSecond)

Method Detail

createPossibleGlobalProperties

protected List<OperatorDescriptorDual.GlobalPropertiesPair> createPossibleGlobalProperties()

Specified by:

createPossibleGlobalProperties in class OperatorDescriptorDual

createPossibleLocalProperties

protected List<OperatorDescriptorDual.LocalPropertiesPair> createPossibleLocalProperties()

Specified by:

createPossibleLocalProperties in class OperatorDescriptorDual

areCompatible

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

Specified by:

areCompatible 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

computeGlobalProperties

public GlobalProperties computeGlobalProperties(GlobalProperties in1,
                                                GlobalProperties in2)

Specified by:

computeGlobalProperties in class OperatorDescriptorDual