Class ParallelismProperty

  • All Implemented Interfaces:

    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 Detail

      • of

        public static ParallelismProperty of​(java.lang.Integer value)
        Static method exposing the constructor.
        value - value of the new execution property.
        the newly created execution property.