pyflink.datastream.data_stream.DataStream.sink_to

DataStream.sink_to(sink: pyflink.datastream.connectors.base.Sink) → pyflink.datastream.data_stream.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.