sets the parallelism for this data sink . the degree must be 1 or more . concode_field_sep int[] sortKeyPositions concode_elem_sep int parallelism concode_elem_sep DataSet<T> data concode_elem_sep Order[] sortOrders concode_elem_sep OutputFormat<T> format concode_elem_sep String name concode_elem_sep TypeInformation<T> type concode_elem_sep Configuration parameters concode_field_sep DataSet<T> getDataSet concode_elem_sep GenericDataSinkBase<T> translateToDataFlow concode_elem_sep int getParallelism concode_elem_sep TypeInformation<T> getType concode_elem_sep DataSink<T> withParameters concode_elem_sep Configuration getParameters concode_elem_sep DataSink<T> name concode_elem_sep OutputFormat<T> getFormat concode_elem_sep String toString concode_elem_sep DataSink<T> sortLocalOutput concode_elem_sep DataSink<T> sortLocalOutput
DataSink < T > function ( int arg0 ) { Preconditions . checkArgument ( arg0 > 0 || arg0 == ExecutionConfig . PARALLELISM_DEFAULT , "srini_string" ) ; this . parallelism = arg0 ; return this ; }