Class PartitionerProperty
- java.lang.Object
-
- org.apache.nemo.common.ir.executionproperty.ExecutionProperty<T>
-
- org.apache.nemo.common.ir.executionproperty.EdgeExecutionProperty<Pair<PartitionerProperty.Type,java.lang.Integer>>
-
- org.apache.nemo.common.ir.edge.executionproperty.PartitionerProperty
-
- All Implemented Interfaces:
java.io.Serializable
public final class PartitionerProperty extends EdgeExecutionProperty<Pair<PartitionerProperty.Type,java.lang.Integer>>
Partitioner ExecutionProperty.- See Also:
- Serialized Form
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
PartitionerProperty.Type
Partitioning types.
-
Field Summary
Fields Modifier and Type Field Description static int
NUM_EQUAL_TO_DST_PARALLELISM
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static PartitionerProperty
of(PartitionerProperty.Type type)
static PartitionerProperty
of(PartitionerProperty.Type type, int numOfPartitions)
static PartitionerProperty
of(Pair<PartitionerProperty.Type,java.lang.Integer> value)
Static constructor.-
Methods inherited from class org.apache.nemo.common.ir.executionproperty.ExecutionProperty
equals, getValue, hashCode, toString
-
-
-
-
Field Detail
-
NUM_EQUAL_TO_DST_PARALLELISM
public static final int NUM_EQUAL_TO_DST_PARALLELISM
- See Also:
- Constant Field Values
-
-
Method Detail
-
of
public static PartitionerProperty of(PartitionerProperty.Type type)
- Parameters:
type
- of the partitioner.- Returns:
- the property.
-
of
public static PartitionerProperty of(PartitionerProperty.Type type, int numOfPartitions)
- Parameters:
type
- of the partitioner.numOfPartitions
- to create.- Returns:
- the property.
-
of
public static PartitionerProperty of(Pair<PartitionerProperty.Type,java.lang.Integer> value)
Static constructor. This is used by reflection by the MetricUtils class.- Parameters:
value
- the Pair value.- Returns:
- the new execution property.
-
-