public class CoGroupWithSolutionSetSecondDescriptor extends CoGroupDescriptor
OperatorDescriptorDual.GlobalPropertiesPair, OperatorDescriptorDual.LocalPropertiesPair
keys1, keys2
Constructor and Description |
---|
CoGroupWithSolutionSetSecondDescriptor(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() |
areCompatible, computeGlobalProperties, createPossibleGlobalProperties, getStrategy, instantiate, setCustomPartitioner
checkEquivalentFieldPositionsInKeyFields, checkEquivalentFieldPositionsInKeyFields, checkSameOrdering, checkSameOrdering, getPossibleGlobalProperties, getPossibleLocalProperties
protected List<OperatorDescriptorDual.LocalPropertiesPair> createPossibleLocalProperties()
createPossibleLocalProperties
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–2020 The Apache Software Foundation. All rights reserved.