pyflink.datastream.data_stream.DataStreamSink.set_parallelism# DataStreamSink.set_parallelism(parallelism: int) → pyflink.datastream.data_stream.DataStreamSink[source]# Sets the parallelism for this operator. Parameters parallelism – THe parallelism for this operator. Returns The operator with set parallelism.