pyflink.datastream.data_stream.CachedDataStream.sink_to

CachedDataStream.sink_to(sink: Sink) → DataStreamSink

Adds the given sink to this DataStream. Only streams with sinks added will be executed once the execute() method is called.

Parameters

sink – The user defined sink.

Returns

The closed DataStream.