This project has retired. For details please refer to its
Attic page .
AvroInputFormat (Apache Crunch 0.5.0-incubating API)
JavaScript is disabled on your browser.
java.lang.Object
org.apache.hadoop.mapreduce.InputFormat<K,V>
org.apache.hadoop.mapreduce.lib.input.FileInputFormat<org.apache.avro.mapred.AvroWrapper<T>,org.apache.hadoop.io.NullWritable>
org.apache.crunch.types.avro.AvroInputFormat<T>
public class AvroInputFormat<T>
extends org.apache.hadoop.mapreduce.lib.input.FileInputFormat<org.apache.avro.mapred.AvroWrapper<T>,org.apache.hadoop.io.NullWritable>
An InputFormat
for Avro data files.
Nested Class Summary
Nested classes/interfaces inherited from class org.apache.hadoop.mapreduce.lib.input.FileInputFormat
org.apache.hadoop.mapreduce.lib.input.FileInputFormat.Counter
Method Summary
Methods
Modifier and Type
Method and Description
org.apache.hadoop.mapreduce.RecordReader<org.apache.avro.mapred.AvroWrapper<T >,org.apache.hadoop.io.NullWritable>
createRecordReader (org.apache.hadoop.mapreduce.InputSplit split,
org.apache.hadoop.mapreduce.TaskAttemptContext context)
Methods inherited from class org.apache.hadoop.mapreduce.lib.input.FileInputFormat
addInputPath, addInputPaths, getInputPathFilter, getInputPaths, getMaxSplitSize, getMinSplitSize, getSplits, setInputPathFilter, setInputPaths, setInputPaths, setMaxInputSplitSize, setMinInputSplitSize
Constructor Detail
AvroInputFormat
public AvroInputFormat()
Method Detail
createRecordReader
public org.apache.hadoop.mapreduce.RecordReader<org.apache.avro.mapred.AvroWrapper<T >,org.apache.hadoop.io.NullWritable> createRecordReader(org.apache.hadoop.mapreduce.InputSplit split,
org.apache.hadoop.mapreduce.TaskAttemptContext context)
throws IOException ,
InterruptedException
Specified by:
createRecordReader
in class org.apache.hadoop.mapreduce.InputFormat<org.apache.avro.mapred.AvroWrapper<T >,org.apache.hadoop.io.NullWritable>
Throws:
IOException
InterruptedException
Copyright © 2013 The Apache Software Foundation . All Rights Reserved.