org.apache.paimon.flink.utils

Class ParallelismUtils

java.lang.Object

org.apache.paimon.flink.utils.ParallelismUtils

public class ParallelismUtils
extends Object

Utility methods about Flink operator parallelism to resolve compatibility issues.

Constructor Summary

Constructors

Constructor and Description
ParallelismUtils()

Method Summary

Modifier and Type	Method and Description
static void	forwardParallelism(org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator<?> targetStream, org.apache.flink.streaming.api.datastream.DataStream<?> sourceStream) Configures the parallelism of the target stream to be the same as the source stream.
static void	setParallelism(org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator<?> targetStream, int parallelism, boolean parallelismConfigured)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ParallelismUtils

public ParallelismUtils()

Method Detail

forwardParallelism

public static void forwardParallelism(org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator<?> targetStream,
                                      org.apache.flink.streaming.api.datastream.DataStream<?> sourceStream)

Configures the parallelism of the target stream to be the same as the source stream. In Flink 1.17+, this method will also configure Transformation.isParallelismConfigured().

setParallelism

public static void setParallelism(org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator<?> targetStream,
                                  int parallelism,
                                  boolean parallelismConfigured)