@PublicEvolving public interface ParallelismProvider
Note: Currently, this interface only works with
|Modifier and Type||Method and Description|
Returns the parallelism for this instance.
default Optional<Integer> getParallelism()
The parallelism denotes how many parallel instances of a source or sink will be spawned during the execution.
Enforcing a different parallelism for sinks might mess up the changelog if the input is
ChangelogMode.insertOnly(). Therefore, a primary key is required by which the
input will be shuffled before records enter the
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.