pyflink.datastream.data_stream.CachedDataStream.add_sink

CachedDataStream.add_sink(sink_func: pyflink.datastream.functions.SinkFunction) → pyflink.datastream.data_stream.DataStreamSink

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.