pyflink.datastream.data_stream.DataStream.add_sink#
- DataStream.add_sink(sink_func: pyflink.datastream.functions.SinkFunction) pyflink.datastream.data_stream.DataStreamSink [source]#
Adds the given sink to this DataStream. Only streams with sinks added will be executed once the StreamExecutionEnvironment.execute() method is called.
- Parameters
sink_func – The SinkFunction object.
- Returns
The closed DataStream.