pyflink.datastream.data_stream.DataStream.union#
- DataStream.union(*streams: pyflink.datastream.data_stream.DataStream) pyflink.datastream.data_stream.DataStream[source]#
Creates a new DataStream by merging DataStream outputs of the same type with each other. The DataStreams merged using this operator will be transformed simultaneously.
- Parameters
streams – The DataStream to union outputwith.
- Returns
The DataStream.