public void setParallelism ( int parallelism ) { if ( parallelism < 1 && parallelism != ExecutionConfig . PARALLELISM_DEFAULT ) { throw new IllegalArgumentException ( "Parallelism of " + parallelism + " is invalid." ) ; } this . parallelism = parallelism ; }
Sets the parallelism for this optimizer node . The parallelism denotes how many parallel instances of the operator will be spawned during the execution .