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.
|
Modifier and Type | Method and Description |
---|---|
void |
addUniqueFieldCombination(FieldSet fields) |
void |
clearUniqueFieldCombinations() |
GlobalProperties |
clone() |
static GlobalProperties |
combine(GlobalProperties gp1,
GlobalProperties gp2) |
boolean |
equals(Object obj) |
GlobalProperties |
filterBySemanticProperties(SemanticProperties props,
int input)
Filters these GlobalProperties by the fields that are forwarded to the output as described by
the SemanticProperties.
|
Partitioner<?> |
getCustomPartitioner() |
DataDistribution |
getDataDistribution() |
PartitioningProperty |
getPartitioning() |
FieldList |
getPartitioningFields() |
Ordering |
getPartitioningOrdering() |
Set<FieldSet> |
getUniqueFieldCombination() |
int |
hashCode() |
boolean |
isExactlyPartitionedOnFields(FieldList fields) |
boolean |
isFullyReplicated() |
boolean |
isPartitionedOnFields(FieldSet fields) |
boolean |
isTrivial()
Checks, if the properties in this object are trivial, i.e. only standard values.
|
boolean |
matchesOrderedPartitioning(Ordering o) |
void |
parameterizeChannel(Channel channel,
boolean globalDopChange,
ExecutionMode exchangeMode,
boolean breakPipeline) |
void |
reset()
This method resets the properties to a state where no properties are given.
|
void |
setAnyPartitioning(FieldList partitionedFields) |
void |
setCustomPartitioned(FieldList partitionedFields,
Partitioner<?> partitioner) |
void |
setForcedRebalanced() |
void |
setFullyReplicated() |
void |
setHashPartitioned(FieldList partitionedFields)
Sets this global properties to represent a hash partitioning.
|
void |
setRandomPartitioned() |
void |
setRangePartitioned(Ordering ordering)
Set the parameters for range partition.
|
void |
setRangePartitioned(Ordering ordering,
DataDistribution distribution)
Set the parameters for range partition.
|
String |
toString() |
public GlobalProperties()
public void setHashPartitioned(FieldList partitionedFields)
partitionedFields
- The key fields on which the data is hash partitioned.public void setRangePartitioned(Ordering ordering)
ordering
- Order of the partitioned fieldspublic void setRangePartitioned(Ordering ordering, DataDistribution distribution)
ordering
- Order of the partitioned fieldsdistribution
- The data distribution for range partition. User can supply a customized
data distribution, also the data distribution can be null.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 DataDistribution getDataDistribution()
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–2024 The Apache Software Foundation. All rights reserved.