File function ( String arg0 , UUID arg1 , HadoopTaskInfo arg2 ) { File loc0 = jobLocalDir ( arg0 , arg1 , arg2 . jobId ( ) ) ; return new File ( loc0 , arg2 . type ( ) + "srini_string" + arg2 . taskNumber ( ) + "srini_string" + arg2 . attempt ( ) ) ; }
returns subdirectory of job working directory for task execution . concode_field_sep String STAGING_CONSTANT concode_elem_sep String OLD_MAP_CLASS_ATTR concode_elem_sep String OLD_REDUCE_CLASS_ATTR concode_field_sep HadoopDefaultJobInfo createJobInfo concode_elem_sep IgniteCheckedException transformException concode_elem_sep HadoopSplitWrapper wrapSplit concode_elem_sep int compareBytes concode_elem_sep void ensureNotSet concode_elem_sep Path stagingAreaDir concode_elem_sep Configuration safeCreateConfiguration concode_elem_sep Object unwrapSplit concode_elem_sep Path jobFile concode_elem_sep File jobLocalDir concode_elem_sep JobStatus status