void function ( int arg0 ) { Preconditions . checkArgument ( arg0 > 0 , "srini_string" ) ; this . parallelism = arg0 ; }
sets the parallelism of this streamtransformation concode_field_sep StreamGraph.ResourceStrategy resourceStrategy concode_elem_sep boolean typeUsed concode_elem_sep int parallelism concode_elem_sep String name concode_elem_sep TypeInformation<T> outputType concode_elem_sep int id concode_elem_sep Integer idCounter concode_elem_sep long bufferTimeout concode_field_sep void setName concode_elem_sep void setBufferTimeout concode_elem_sep TypeInformation<T> getOutputType concode_elem_sep String getName concode_elem_sep long getBufferTimeout concode_elem_sep void setResourceStrategy concode_elem_sep int getId concode_elem_sep void setOutputType concode_elem_sep int getNewNodeId concode_elem_sep int getParallelism concode_elem_sep int hashCode concode_elem_sep boolean equals concode_elem_sep String toString concode_elem_sep void setChainingStrategy concode_elem_sep Collection<StreamTransformation<?>> getTransitivePredecessors concode_elem_sep StreamGraph.ResourceStrategy getResourceStrategy