@SuppressWarnings("deprecation")
@Override
public void initialize(InputSplit split, TaskAttemptContext ctx)
throws IOException, InterruptedException {
FileSplit fileSplit = (FileSplit)split;
Configuration conf = ctx.getConfiguration();
splitPath = fileSplit.getPath();
rcFileRecordReader = new RCFileRecordReader<LongWritable, BytesRefArrayWritable>(conf,
new org.apache.hadoop.mapred.FileSplit(splitPath, fileSplit.getStart(), fileSplit.getLength(),
new org.apache.hadoop.mapred.JobConf(conf)) );
key = rcFileRecordReader.createKey();
value = rcFileRecordReader.createValue();