public static LzoW3CLogInputFormat newInstance ( final String fieldDefinitionFile ) { return new LzoW3CLogInputFormat ( ) { @ Override public RecordReader < LongWritable , MapWritable > createRecordReader ( InputSplit split , TaskAttemptContext context ) throws IOException , InterruptedException { RecordReader < LongWritable , MapWritable > reader = new LzoW3CLogRecordReader ( ) { @ Override protected String getFieldDefinitionFile ( ) { return fieldDefinitionFile ; } } ; reader . initialize ( split , context ) ; return reader ; } } ; }
Use this method to create valid instances of LzoW3CLogInputFormat