datafu.hourglass.avro
Class CombinedAvroKeyInputFormat.CombinedAvroKeyRecordReader<T>

java.lang.Object
  org.apache.hadoop.mapreduce.RecordReader<K,V>
      org.apache.avro.mapreduce.AvroRecordReaderBase<org.apache.avro.mapred.AvroKey<T>,org.apache.hadoop.io.NullWritable,T>
          org.apache.avro.mapreduce.AvroKeyRecordReader<T>
              datafu.hourglass.avro.CombinedAvroKeyInputFormat.CombinedAvroKeyRecordReader<T>

All Implemented Interfaces:

java.io.Closeable

Enclosing class:

CombinedAvroKeyInputFormat<T>

public static class CombinedAvroKeyInputFormat.CombinedAvroKeyRecordReader<T>
extends org.apache.avro.mapreduce.AvroKeyRecordReader<T>

Constructor Summary

CombinedAvroKeyInputFormat.CombinedAvroKeyRecordReader(org.apache.hadoop.mapreduce.lib.input.CombineFileSplit inputSplit, org.apache.hadoop.mapreduce.TaskAttemptContext context, java.lang.Integer idx)

Method Summary

void	initialize(org.apache.hadoop.mapreduce.InputSplit inputSplit, org.apache.hadoop.mapreduce.TaskAttemptContext context)

Methods inherited from class org.apache.avro.mapreduce.AvroKeyRecordReader

getCurrentKey, getCurrentValue, nextKeyValue

Methods inherited from class org.apache.avro.mapreduce.AvroRecordReaderBase

close, createAvroFileReader, createSeekableInput, getCurrentRecord, getProgress

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CombinedAvroKeyInputFormat.CombinedAvroKeyRecordReader

public CombinedAvroKeyInputFormat.CombinedAvroKeyRecordReader(org.apache.hadoop.mapreduce.lib.input.CombineFileSplit inputSplit,
                                                              org.apache.hadoop.mapreduce.TaskAttemptContext context,
                                                              java.lang.Integer idx)

Method Detail

initialize

public void initialize(org.apache.hadoop.mapreduce.InputSplit inputSplit,
                       org.apache.hadoop.mapreduce.TaskAttemptContext context)
                throws java.io.IOException,
                       java.lang.InterruptedException

Overrides:

initialize in class org.apache.avro.mapreduce.AvroRecordReaderBase<org.apache.avro.mapred.AvroKey<T>,org.apache.hadoop.io.NullWritable,T>

Throws:

java.io.IOException

java.lang.InterruptedException