pyflink.datastream.data_stream.DataStream.get_side_output

DataStream.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 given OutputTag.

Parameters

output_tag – output tag for the side stream

Returns

The DataStream with specified output tag

New in version 1.16.0.