ParallelismProperty (Nemo Project 0.4 API)

java.lang.Object
- org.apache.nemo.common.ir.executionproperty.ExecutionProperty<T>
- - org.apache.nemo.common.ir.executionproperty.VertexExecutionProperty<java.lang.Integer>
  - - org.apache.nemo.common.ir.vertex.executionproperty.ParallelismProperty

All Implemented Interfaces:

java.io.Serializable
```
public final class ParallelismProperty
extends VertexExecutionProperty<java.lang.Integer>
```
This property decides the number of parallel tasks to use for executing the corresponding IRVertex.
Changing the parallelism requires also changing other execution properties that refer to task offsets. Such execution properties include: ResourceSiteProperty ResourceAntiAffinityProperty PartitionerProperty PartitionSetProperty
Moreover, vertices with one-to-one relationships must have the same parallelism. CommunicationPatternProperty
Finally, the parallelism cannot be larger than the number of source (e.g., HDFS) input data partitions. SourceVertex
A violation of any of the above criteria will be caught by Nemo, to ensure correct application semantics.

See Also:

Serialized Form

- Method Summary
  
  All Methods Static Methods Concrete Methods
  Modifier and Type Method Description
  
  static ParallelismProperty of(java.lang.Integer 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

- Method Detail
  - of
```
public static ParallelismProperty of(java.lang.Integer value)
```
    Static method exposing the constructor.
    
    Parameters:
    
    value - value of the new execution property.
    
    Returns:
    
    the newly created execution property.