code: public static LocalEnvironment createLocalEnvironment(int degreeOfParallelism) {
  		LocalEnvironment lee = new LocalEnvironment();
  		lee.setDegreeOfParallelism(degreeOfParallelism);
  		return lee;
  	}
docs: Creates a {@link LocalEnvironment}. 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
  degree of parallelism specified in the parameter.
  
  @param degreeOfParallelism The degree of parallelism for the local environment.
  @return A local execution environment with the specified degree of parallelism.