code: public static LocalStreamEnvironment createLocalEnvironment(int parallelism, Configuration configuration) {
  		final LocalStreamEnvironment currentEnvironment;
  
  		currentEnvironment = new LocalStreamEnvironment(configuration);
  		currentEnvironment.setParallelism(parallelism);
  
  		return currentEnvironment;
  	}
docs: Creates a {@link LocalStreamEnvironment}. The local execution environment
  will run the program in a multi-threaded fashion in the same JVM as the
  environment was created in. It will use the parallelism specified in the
  parameter.
  
  @param parallelism
  The parallelism for the local environment.
  @param configuration
  Pass a custom configuration into the cluster
  @return A local execution environment with the specified parallelism.