public static int getParallelism ( String [ ] args , int defaultParallelism ) { return ( args . length > 1 ) ? Integer . parseInt ( args [ 1 ] ) : defaultParallelism ; }
Fetches the topology s parallelism from the second - command - line argument or defers to a supplied default .