pyflink.datastream.data_stream.CachedDataStream.union

CachedDataStream.union(*streams: DataStream) → DataStream

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.