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.
- Returns
This object.