docs: @Internal
  	public <R> SingleOutputStreamOperator<R> process(
  			KeyedProcessFunction<KEY, T, R> keyedProcessFunction,
  			TypeInformation<R> outputType) {
  
  		KeyedProcessOperator<KEY, T, R> operator = new KeyedProcessOperator<>(clean(keyedProcessFunction));
  		return transform("KeyedProcess", outputType, operator);
  	}