@PublicEvolving public interface ParallelismProvider
Note: Currently, this interface can only work with org.apache.flink.table.connector.sink.SinkFunctionProvider
in flink-table-api-java-bridge
module and OutputFormatProvider
.
Modifier and Type | Method and Description |
---|---|
default Optional<Integer> |
getParallelism()
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.
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.