void function ( Configuration arg0 ) { Job loc0 = Job . getInstance ( arg0 ) ; loc0 . setJarByClass ( TestLineRecordReaderJobs . class ) ; loc0 . setMapperClass ( Mapper . class ) ; loc0 . setReducerClass ( Reducer . class ) ; FileInputFormat . addInputPath ( loc0 , inputDir ) ; FileOutputFormat . setOutputPath ( loc0 , outputDir ) ; loc0 . waitForCompletion ( true ) ; }
creates and runs an mr job concode_field_sep Path outputDir concode_elem_sep Path workDir concode_elem_sep Path inputDir concode_field_sep void testCustomRecordDelimiters concode_elem_sep void testDefaultRecordDelimiters concode_elem_sep void createInputFile concode_elem_sep String readOutputFile