Package org.apache.nemo.common.ir.edge.executionproperty

Class SubPartitionSetProperty

java.lang.Object

org.apache.nemo.common.ir.executionproperty.ExecutionProperty<T>

org.apache.nemo.common.ir.executionproperty.EdgeExecutionProperty<java.util.ArrayList<KeyRange>>

org.apache.nemo.common.ir.edge.executionproperty.SubPartitionSetProperty

All Implemented Interfaces:

java.io.Serializable

public class SubPartitionSetProperty
extends EdgeExecutionProperty<java.util.ArrayList<KeyRange>>

This property decides the hash partition set of sampled and optimized tasks in Dynamic Task Sizing Policy.

Adopting this property requires changing other properties as well. Such execution properties include: PartitionerProperty ParallelismProperty

Changing order matters: one must need to change PartitionerProperty, SubPartitionSetProperty, and ParallelismProperty sequentially.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
SubPartitionSetProperty(java.util.ArrayList<KeyRange> value)	Default constructor.

Method Summary

Modifier and Type	Method	Description
static SubPartitionSetProperty	of(java.util.ArrayList<KeyRange> value)	Static method exposing the constructor.

Methods inherited from class org.apache.nemo.common.ir.executionproperty.ExecutionProperty

equals, getValue, hashCode, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

SubPartitionSetProperty

public SubPartitionSetProperty(java.util.ArrayList<KeyRange> value)

Default constructor.

Parameters:

value - value of the EdgeExecutionProperty.

Method Detail

of

public static SubPartitionSetProperty of(java.util.ArrayList<KeyRange> value)

Static method exposing the constructor.

Parameters:

value - value of the new execution property.

Returns:

the newly created execution property.