Modifier and Type | Method and Description |
---|---|
SinkStage |
setLocalParallelism(int localParallelism)
Sets the preferred local parallelism (number of workers per Jet
cluster member) this stage will configure its DAG vertices with.
|
SinkStage |
setName(String name)
Overrides the default name of the stage with the name you choose.
|
getPipeline, name
@Nonnull SinkStage setLocalParallelism(int localParallelism)
Stage
Note that, while most stages are backed by 1 vertex, there are exceptions. If a stage uses two vertices, each of them will have the given local parallelism, so in total there will be twice as many processing units per member.
The default value is -1 and it signals to Jet to figure out a default value. Jet will determine the vertex's local parallelism during job initialization from the global default and the processor meta-supplier's preferred value.
setLocalParallelism
in interface Stage
Copyright © 2018 Hazelcast, Inc.. All rights reserved.