public class GlobalProperties extends Object implements Cloneable
Modifier and Type | Field and Description |
---|---|
static org.slf4j.Logger |
LOG |
Constructor and Description |
---|
GlobalProperties()
Initializes the global properties with no partitioning.
|
public GlobalProperties()
public void setHashPartitioned(FieldList partitionedFields)
partitionedFields
- The key fields on which the data is hash partitioned.public void setRangePartitioned(Ordering ordering)
public void setAnyPartitioning(FieldList partitionedFields)
public void setRandomPartitioned()
public void setFullyReplicated()
public void setForcedRebalanced()
public void setCustomPartitioned(FieldList partitionedFields, Partitioner<?> partitioner)
public void addUniqueFieldCombination(FieldSet fields)
public void clearUniqueFieldCombinations()
public FieldList getPartitioningFields()
public Ordering getPartitioningOrdering()
public PartitioningProperty getPartitioning()
public Partitioner<?> getCustomPartitioner()
public boolean isPartitionedOnFields(FieldSet fields)
public boolean isExactlyPartitionedOnFields(FieldList fields)
public boolean matchesOrderedPartitioning(Ordering o)
public boolean isFullyReplicated()
public boolean isTrivial()
public void reset()
public GlobalProperties filterBySemanticProperties(SemanticProperties props, int input)
props
- The semantic properties holding information about forwarded fields.input
- The index of the input.public void parameterizeChannel(Channel channel, boolean globalDopChange, ExecutionMode exchangeMode, boolean breakPipeline)
public GlobalProperties clone()
public static GlobalProperties combine(GlobalProperties gp1, GlobalProperties gp2)
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.