pyflink.datastream.data_stream.DataStream.start_new_chain# DataStream.start_new_chain() → 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.
