pyflink.datastream.data_stream.CachedDataStream.sink_to#
- CachedDataStream.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.