org.apache.flink.optimizer.operators

Class CoGroupWithSolutionSetFirstDescriptor

java.lang.Object

org.apache.flink.optimizer.operators.OperatorDescriptorDual

org.apache.flink.optimizer.operators.CoGroupDescriptor

org.apache.flink.optimizer.operators.CoGroupWithSolutionSetFirstDescriptor

All Implemented Interfaces:

AbstractOperatorDescriptor

public class CoGroupWithSolutionSetFirstDescriptor
extends CoGroupDescriptor

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 and Description
CoGroupWithSolutionSetFirstDescriptor(FieldList keys1, FieldList keys2)

Method Summary

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

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

areCompatible, computeGlobalProperties, createPossibleGlobalProperties, getStrategy, setCustomPartitioner

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

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

CoGroupWithSolutionSetFirstDescriptor

public CoGroupWithSolutionSetFirstDescriptor(FieldList keys1,
                                             FieldList keys2)

Method Detail

createPossibleLocalProperties

protected List<OperatorDescriptorDual.LocalPropertiesPair> createPossibleLocalProperties()

Overrides:

createPossibleLocalProperties in class CoGroupDescriptor

instantiate

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

Overrides:

instantiate in class CoGroupDescriptor

areCoFulfilled

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

Overrides:

areCoFulfilled in class CoGroupDescriptor

computeLocalProperties

public LocalProperties computeLocalProperties(LocalProperties in1,
                                              LocalProperties in2)

Overrides:

computeLocalProperties in class CoGroupDescriptor