pyflink.datastream.data_stream.KeyedStream.add_sink# KeyedStream.add_sink(sink_func: SinkFunction) → DataStreamSink[source]# 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.