code: @PublicEvolving
  	public void add_sink(SinkFunction<PyObject> sink_func) throws IOException {
  		stream.addSink(new PythonSinkFunction(sink_func));
  	}
docs: A thin wrapper layer over {@link DataStream#addSink(SinkFunction)}.
  
  @param sink_func The object containing the sink's invoke function.