docs: public static LocalStreamEnvironment createLocalEnvironment(int parallelism, Configuration configuration) {
  		final LocalStreamEnvironment currentEnvironment;
  
  		currentEnvironment = new LocalStreamEnvironment(configuration);
  		currentEnvironment.setParallelism(parallelism);
  
  		return currentEnvironment;
  	}