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, java.lang.AutoCloseable

Enclosing class:

CombinedAvroKeyInputFormat<T>

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

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
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