public SingleOutputStreamOperator < T > setParallelism ( int parallelism ) { Preconditions . checkArgument ( canBeParallel ( ) || parallelism == 1 , "The parallelism of non parallel operator must be 1." ) ; transformation . setParallelism ( parallelism ) ; return this ; }
Sets the parallelism for this operator .