@PublicEvolving public interface ParallelismProvider
The parallelism denotes how many parallel instances of a source or sink will be spawned during the execution.
Enforcing a different parallelism for sources/sinks might mess up the changelog if the
output/input is not
ChangelogMode.insertOnly(). Therefore, a primary key is required
by which the output/input will be shuffled after/before records leave/enter the
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.