public abstract class AbstractJoinDescriptor extends OperatorDescriptorDual
OperatorDescriptorDual.GlobalPropertiesPair, OperatorDescriptorDual.LocalPropertiesPair
keys1, keys2
Modifier | Constructor and Description |
---|---|
protected |
AbstractJoinDescriptor(FieldList keys1,
FieldList keys2) |
protected |
AbstractJoinDescriptor(FieldList keys1,
FieldList keys2,
boolean broadcastFirstAllowed,
boolean broadcastSecondAllowed,
boolean repartitionAllowed) |
Modifier and Type | Method and Description |
---|---|
boolean |
areCompatible(RequestedGlobalProperties requested1,
RequestedGlobalProperties requested2,
GlobalProperties produced1,
GlobalProperties produced2) |
GlobalProperties |
computeGlobalProperties(GlobalProperties in1,
GlobalProperties in2) |
protected List<OperatorDescriptorDual.GlobalPropertiesPair> |
createPossibleGlobalProperties() |
void |
setCustomPartitioner(Partitioner<?> partitioner) |
areCoFulfilled, checkEquivalentFieldPositionsInKeyFields, checkEquivalentFieldPositionsInKeyFields, checkSameOrdering, checkSameOrdering, computeLocalProperties, createPossibleLocalProperties, getPossibleGlobalProperties, getPossibleLocalProperties, instantiate
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getStrategy
public void setCustomPartitioner(Partitioner<?> partitioner)
protected List<OperatorDescriptorDual.GlobalPropertiesPair> createPossibleGlobalProperties()
createPossibleGlobalProperties
in class OperatorDescriptorDual
public boolean areCompatible(RequestedGlobalProperties requested1, RequestedGlobalProperties requested2, GlobalProperties produced1, GlobalProperties produced2)
areCompatible
in class OperatorDescriptorDual
public GlobalProperties computeGlobalProperties(GlobalProperties in1, GlobalProperties in2)
computeGlobalProperties
in class OperatorDescriptorDual
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.