public class CoGroupWithSolutionSetFirstDescriptor extends CoGroupDescriptor
OperatorDescriptorDual.GlobalPropertiesPair, OperatorDescriptorDual.LocalPropertiesPair
keys1, keys2
Constructor and Description |
---|
CoGroupWithSolutionSetFirstDescriptor(FieldList keys1,
FieldList keys2) |
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) |
areCompatible, computeGlobalProperties, createPossibleGlobalProperties, getStrategy, setCustomPartitioner
checkEquivalentFieldPositionsInKeyFields, checkEquivalentFieldPositionsInKeyFields, checkSameOrdering, checkSameOrdering, getPossibleGlobalProperties, getPossibleLocalProperties
protected List<OperatorDescriptorDual.LocalPropertiesPair> createPossibleLocalProperties()
createPossibleLocalProperties
in class CoGroupDescriptor
public DualInputPlanNode instantiate(Channel in1, Channel in2, TwoInputNode node)
instantiate
in class CoGroupDescriptor
public boolean areCoFulfilled(RequestedLocalProperties requested1, RequestedLocalProperties requested2, LocalProperties produced1, LocalProperties produced2)
areCoFulfilled
in class CoGroupDescriptor
public LocalProperties computeLocalProperties(LocalProperties in1, LocalProperties in2)
computeLocalProperties
in class CoGroupDescriptor
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.