pyflink.datastream.data_stream.KeyedStream.union#
- KeyedStream.union(*streams) 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.