Package org.apache.flink.optimizer.operators

Class CrossBlockOuterFirstDescriptor

java.lang.Object

org.apache.flink.optimizer.operators.OperatorDescriptorDual

org.apache.flink.optimizer.operators.CartesianProductDescriptor

org.apache.flink.optimizer.operators.CrossBlockOuterFirstDescriptor

All Implemented Interfaces:

AbstractOperatorDescriptor

public class CrossBlockOuterFirstDescriptor
extends CartesianProductDescriptor

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

Method Summary

Modifier and Type	Method	Description
LocalProperties	computeLocalProperties(LocalProperties in1, LocalProperties in2)
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.CartesianProductDescriptor

areCoFulfilled, areCompatible, computeGlobalProperties, createPossibleGlobalProperties, createPossibleLocalProperties, instantiate

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

CrossBlockOuterFirstDescriptor

public CrossBlockOuterFirstDescriptor()

CrossBlockOuterFirstDescriptor

public CrossBlockOuterFirstDescriptor(boolean allowBroadcastFirst,
                                      boolean allowBroadcastSecond)

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.

computeLocalProperties

public LocalProperties computeLocalProperties(LocalProperties in1,
                                              LocalProperties in2)

Specified by:

computeLocalProperties in class OperatorDescriptorDual