void function ( int arg0 ) { if ( arg0 < 1 ) { throw new IllegalArgumentException ( "srini_string" ) ; } this . parallelism = arg0 ; }
sets the parallelism for the task . concode_field_sep String invokableClassName concode_elem_sep ArrayList<JobEdge> inputs concode_elem_sep int parallelism concode_elem_sep CoLocationGroup coLocationGroup concode_elem_sep Configuration configuration concode_elem_sep InputSplitSource<?> inputSplitSource concode_elem_sep ArrayList<IntermediateDataSet> results concode_elem_sep String name concode_elem_sep SlotSharingGroup slotSharingGroup concode_elem_sep long serialVersionUID concode_elem_sep JobVertexID id concode_elem_sep String DEFAULT_NAME concode_field_sep void setName concode_elem_sep IntermediateDataSet createAndAddResultDataSet concode_elem_sep IntermediateDataSet createAndAddResultDataSet concode_elem_sep String getName concode_elem_sep void connectDataSetAsInput concode_elem_sep InputSplitSource<?> getInputSplitSource concode_elem_sep boolean isInputVertex concode_elem_sep int getNumberOfInputs concode_elem_sep String getInvokableClassName concode_elem_sep void setSlotSharingGroup concode_elem_sep void setInputSplitSource concode_elem_sep void connectIdInput concode_elem_sep Configuration getConfiguration concode_elem_sep int getParallelism concode_elem_sep CoLocationGroup getCoLocationGroup concode_elem_sep List<JobEdge> getInputs concode_elem_sep boolean hasNoConnectedInputs concode_elem_sep void initializeOnMaster concode_elem_sep void setInvokableClass concode_elem_sep void connectNewDataSetAsInput concode_elem_sep void connectNewDataSetAsInput concode_elem_sep Class<? extends AbstractInvokable> getInvokableClass concode_elem_sep SlotSharingGroup getSlotSharingGroup concode_elem_sep int getNumberOfProducedIntermediateDataSets concode_elem_sep void updateCoLocationGroup concode_elem_sep JobVertexID getID concode_elem_sep boolean isOutputVertex concode_elem_sep void setStrictlyCoLocatedWith concode_elem_sep void finalizeOnMaster concode_elem_sep String toString concode_elem_sep List<IntermediateDataSet> getProducedDataSets