code: @PublicEvolving
  	public DataStreamSink<T> writeToSocket(String hostName, int port, SerializationSchema<T> schema) {
  		DataStreamSink<T> returnStream = addSink(new SocketClientSink<>(hostName, port, schema, 0));
  		returnStream.setParallelism(1); // It would not work if multiple instances would connect to the same port
  		return returnStream;
  	}
docs: Writes the DataStream to a socket as a byte array. The format of the
  output is specified by a {@link SerializationSchema}.
  
  @param hostName
  host of the socket
  @param port
  port of the socket
  @param schema
  schema for serialization
  @return the closed DataStream