pyflink.datastream.data_stream.DataStream.start_new_chain# DataStream.start_new_chain() → pyflink.datastream.data_stream.DataStream[source]# Starts a new task chain beginning at this operator. This operator will be chained (thread co-located for increased performance) to any previous tasks even if possible. Returns The operator with chaining set.