public class CoGroupRawDescriptor extends OperatorDescriptorDual
OperatorDescriptorDual.GlobalPropertiesPair, OperatorDescriptorDual.LocalPropertiesPair
keys1, keys2
Constructor and Description |
---|
CoGroupRawDescriptor(FieldList keys1,
FieldList keys2) |
CoGroupRawDescriptor(FieldList keys1,
FieldList keys2,
Ordering additionalOrdering1,
Ordering additionalOrdering2) |
Modifier and Type | Method and 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) |
LocalProperties |
computeLocalProperties(LocalProperties in1,
LocalProperties in2) |
protected List<OperatorDescriptorDual.GlobalPropertiesPair> |
createPossibleGlobalProperties() |
protected List<OperatorDescriptorDual.LocalPropertiesPair> |
createPossibleLocalProperties() |
DriverStrategy |
getStrategy()
Gets the runtime strategy to be executed by this operator.
|
DualInputPlanNode |
instantiate(Channel in1,
Channel in2,
TwoInputNode node) |
checkEquivalentFieldPositionsInKeyFields, checkEquivalentFieldPositionsInKeyFields, checkSameOrdering, checkSameOrdering, getPossibleGlobalProperties, getPossibleLocalProperties
public DriverStrategy getStrategy()
AbstractOperatorDescriptor
protected List<OperatorDescriptorDual.GlobalPropertiesPair> createPossibleGlobalProperties()
createPossibleGlobalProperties
in class OperatorDescriptorDual
protected List<OperatorDescriptorDual.LocalPropertiesPair> createPossibleLocalProperties()
createPossibleLocalProperties
in class OperatorDescriptorDual
public boolean areCoFulfilled(RequestedLocalProperties requested1, RequestedLocalProperties requested2, LocalProperties produced1, LocalProperties produced2)
areCoFulfilled
in class OperatorDescriptorDual
public DualInputPlanNode instantiate(Channel in1, Channel in2, TwoInputNode node)
instantiate
in class OperatorDescriptorDual
public GlobalProperties computeGlobalProperties(GlobalProperties in1, GlobalProperties in2)
computeGlobalProperties
in class OperatorDescriptorDual
public LocalProperties computeLocalProperties(LocalProperties in1, LocalProperties in2)
computeLocalProperties
in class OperatorDescriptorDual
public boolean areCompatible(RequestedGlobalProperties requested1, RequestedGlobalProperties requested2, GlobalProperties produced1, GlobalProperties produced2)
areCompatible
in class OperatorDescriptorDual
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.