| Package | Description | 
|---|---|
| org.apache.avro.hadoop.io | |
| org.apache.avro.mapred | 
 Run Hadoop MapReduce jobs over
Avro data, with map and reduce functions written in Java. 
 | 
| org.apache.trevni.avro | 
 Read and write Avro data
in Trevni column files. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
AvroDeserializer<T extends AvroWrapper<D>,D>
Deserializes AvroWrapper objects within Hadoop. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
protected AvroWrapper<D> | 
AvroValueDeserializer.createAvroWrapper()
Creates a new empty  
AvroValue instance. | 
protected AvroWrapper<D> | 
AvroKeyDeserializer.createAvroWrapper()
Creates a new empty  
AvroKey instance. | 
| Modifier and Type | Method and Description | 
|---|---|
org.apache.hadoop.io.serializer.Deserializer<AvroWrapper<T>> | 
AvroSerialization.getDeserializer(Class<AvroWrapper<T>> c)
Gets an object capable of deserializing the output from a Mapper. 
 | 
org.apache.hadoop.io.serializer.Serializer<AvroWrapper<T>> | 
AvroSerialization.getSerializer(Class<AvroWrapper<T>> c)
Gets an object capable of serializing output from a Mapper. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Object | 
AvroDatumConverterFactory.AvroWrapperConverter.convert(AvroWrapper<?> input) | 
void | 
AvroSerializer.serialize(AvroWrapper<T> avroWrapper) | 
| Modifier and Type | Method and Description | 
|---|---|
org.apache.hadoop.io.serializer.Deserializer<AvroWrapper<T>> | 
AvroSerialization.getDeserializer(Class<AvroWrapper<T>> c)
Gets an object capable of deserializing the output from a Mapper. 
 | 
org.apache.hadoop.io.serializer.Serializer<AvroWrapper<T>> | 
AvroSerialization.getSerializer(Class<AvroWrapper<T>> c)
Gets an object capable of serializing output from a Mapper. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
AvroKey<T>
The wrapper of keys for jobs configured with  
AvroJob . | 
class  | 
AvroValue<T>
The wrapper of values for jobs configured with  
AvroJob . | 
| Modifier and Type | Method and Description | 
|---|---|
AvroWrapper<T> | 
AvroRecordReader.createKey()  | 
| Modifier and Type | Method and Description | 
|---|---|
org.apache.hadoop.io.serializer.Deserializer<AvroWrapper<T>> | 
AvroSerialization.getDeserializer(Class<AvroWrapper<T>> c)
Returns the specified map output deserializer. 
 | 
org.apache.hadoop.mapred.RecordReader<AvroWrapper<Pair<K,V>>,org.apache.hadoop.io.NullWritable> | 
SequenceFileInputFormat.getRecordReader(org.apache.hadoop.mapred.InputSplit split,
               org.apache.hadoop.mapred.JobConf job,
               org.apache.hadoop.mapred.Reporter reporter)  | 
org.apache.hadoop.mapred.RecordReader<AvroWrapper<T>,org.apache.hadoop.io.NullWritable> | 
AvroInputFormat.getRecordReader(org.apache.hadoop.mapred.InputSplit split,
               org.apache.hadoop.mapred.JobConf job,
               org.apache.hadoop.mapred.Reporter reporter)  | 
org.apache.hadoop.mapred.RecordReader<AvroWrapper<Utf8>,org.apache.hadoop.io.NullWritable> | 
AvroUtf8InputFormat.getRecordReader(org.apache.hadoop.mapred.InputSplit split,
               org.apache.hadoop.mapred.JobConf job,
               org.apache.hadoop.mapred.Reporter reporter)  | 
org.apache.hadoop.mapred.RecordWriter<AvroWrapper<T>,org.apache.hadoop.io.NullWritable> | 
AvroOutputFormat.getRecordWriter(org.apache.hadoop.fs.FileSystem ignore,
               org.apache.hadoop.mapred.JobConf job,
               String name,
               org.apache.hadoop.util.Progressable prog)  | 
org.apache.hadoop.io.serializer.Serializer<AvroWrapper<T>> | 
AvroSerialization.getSerializer(Class<AvroWrapper<T>> c)
Returns the specified output serializer. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
int | 
AvroKeyComparator.compare(AvroWrapper<T> x,
       AvroWrapper<T> y)  | 
int | 
AvroKeyComparator.compare(AvroWrapper<T> x,
       AvroWrapper<T> y)  | 
boolean | 
AvroRecordReader.next(AvroWrapper<T> wrapper,
    org.apache.hadoop.io.NullWritable ignore)  | 
| Modifier and Type | Method and Description | 
|---|---|
org.apache.hadoop.io.serializer.Deserializer<AvroWrapper<T>> | 
AvroSerialization.getDeserializer(Class<AvroWrapper<T>> c)
Returns the specified map output deserializer. 
 | 
org.apache.hadoop.io.serializer.Serializer<AvroWrapper<T>> | 
AvroSerialization.getSerializer(Class<AvroWrapper<T>> c)
Returns the specified output serializer. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
org.apache.hadoop.mapred.RecordReader<AvroWrapper<T>,org.apache.hadoop.io.NullWritable> | 
AvroTrevniInputFormat.getRecordReader(org.apache.hadoop.mapred.InputSplit split,
               org.apache.hadoop.mapred.JobConf job,
               org.apache.hadoop.mapred.Reporter reporter)  | 
org.apache.hadoop.mapred.RecordWriter<AvroWrapper<T>,org.apache.hadoop.io.NullWritable> | 
AvroTrevniOutputFormat.getRecordWriter(org.apache.hadoop.fs.FileSystem ignore,
               org.apache.hadoop.mapred.JobConf job,
               String name,
               org.apache.hadoop.util.Progressable prog)  | 
Copyright © 2009–2021 The Apache Software Foundation. All rights reserved.