docs: @PublicEvolving
  	public DataStreamSource<String> socketTextStream(String hostname, int port, String delimiter, long maxRetry) {
  		return addSource(new SocketTextStreamFunction(hostname, port, delimiter, maxRetry),
  				"Socket Stream");
  	}