@PublicEvolving public interface ParallelismProvider
Note: Currently, this interface only works with
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.