docs: @SuppressWarnings("unchecked")
  	public PythonSingleOutputStreamOperator reduce(ReduceFunction<PyObject> fun) throws IOException {
  		return new PythonSingleOutputStreamOperator(stream.reduce(new PythonReduceFunction(fun)));
  	}