pyflink.datastream.data_stream.DataStreamSink.disable_chaining

DataStreamSink.disable_chaining() → pyflink.datastream.data_stream.DataStreamSink

Turns off chaining for this operator so thread co-location will not be used as an optimization. Chaining can be turned off for the whole job by StreamExecutionEnvironment.disableOperatorChaining() however it is not advised for performance consideration.

Returns

The operator with chaining disabled.