code: @PublicEvolving
  	public void write_to_socket(String host, Integer port, SerializationSchema<PyObject> schema) throws IOException {
  		stream.writeToSocket(host, port, new PythonSerializationSchema(schema));
  	}
docs: A thin wrapper layer over {@link DataStream#writeToSocket(String, int, org.apache.flink.api.common.serialization.SerializationSchema)}.
  
  @param host host of the socket
  @param port port of the socket
  @param schema schema for serialization