pyflink.datastream.data_stream.DataStream.sink_to# DataStream.sink_to(sink: Sink) → DataStreamSink[source]# 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.
