pyflink.datastream.data_stream.CachedDataStream.get_side_output#
- CachedDataStream.get_side_output(output_tag: pyflink.datastream.output_tag.OutputTag) pyflink.datastream.data_stream.DataStream #
Gets the
DataStream
that contains the elements that are emitted from an operation into the side output with the givenOutputTag
.- Parameters
output_tag – output tag for the side stream
- Returns
The DataStream with specified output tag
New in version 1.16.0.