docs: @Internal
  	public <R> SingleOutputStreamOperator<R> process(
  			ProcessFunction<T, R> processFunction,
  			TypeInformation<R> outputType) {
  
  		ProcessOperator<T, R> operator = new ProcessOperator<>(clean(processFunction));
  
  		return transform("Process", outputType, operator);
  	}