pyflink.datastream.stream_execution_environment.StreamExecutionEnvironment.disable_operator_chaining#

StreamExecutionEnvironment.disable_operator_chaining() → pyflink.datastream.stream_execution_environment.StreamExecutionEnvironment[source]#

Disables operator chaining for streaming operators. Operator chaining allows non-shuffle operations to be co-located in the same thread fully avoiding serialization and de-serialization.