pyflink.datastream.data_stream.DataStreamSink.set_parallelism

DataStreamSink.set_parallelism(parallelism: int) → DataStreamSink

Sets the parallelism for this operator.

Parameters:

parallelism – THe parallelism for this operator.

Returns:

The operator with set parallelism.