public DataSink < T > setParallelism ( int parallelism ) { Preconditions . checkArgument ( parallelism > 0 || parallelism == ExecutionConfig . PARALLELISM_DEFAULT , "The parallelism of an operator must be at least 1." ) ; this . parallelism = parallelism ; return this ; }
Sets the parallelism for this data sink . The degree must be 1 or more .