core/src/main/java/com/twitter/elephantbird/mapreduce/input/LzoW3CLogInputFormat.java
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;
      }
    };
  }
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;
      }
    };
  }
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
@param fieldDefinitionFile path to file in HDFS that contains the CRC hash to column mappings.
@return
Use this method to create valid instances of LzoW3CLogInputFormat