pyflink.datastream.data_stream.DataStream.disable_chaining

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

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.