| Package | Description |
|---|---|
| org.apache.avro.mapred |
Run Hadoop MapReduce jobs over
Avro data, with map and reduce functions written in Java.
|
| 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 |
|---|---|
Deserializer<AvroWrapper<T>> |
AvroSerialization.getDeserializer(Class<AvroWrapper<T>> c)
Returns the specified map output deserializer.
|
RecordReader<AvroWrapper<T>,NullWritable> |
AvroInputFormat.getRecordReader(InputSplit split,
JobConf job,
Reporter reporter) |
RecordReader<AvroWrapper<Pair<K,V>>,NullWritable> |
SequenceFileInputFormat.getRecordReader(InputSplit split,
JobConf job,
Reporter reporter) |
RecordReader<AvroWrapper<Utf8>,NullWritable> |
AvroUtf8InputFormat.getRecordReader(InputSplit split,
JobConf job,
Reporter reporter) |
RecordWriter<AvroWrapper<T>,NullWritable> |
AvroOutputFormat.getRecordWriter(FileSystem ignore,
JobConf job,
String name,
Progressable prog) |
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,
NullWritable ignore) |
| Modifier and Type | Method and Description |
|---|---|
Deserializer<AvroWrapper<T>> |
AvroSerialization.getDeserializer(Class<AvroWrapper<T>> c)
Returns the specified map output deserializer.
|
Serializer<AvroWrapper<T>> |
AvroSerialization.getSerializer(Class<AvroWrapper<T>> c)
Returns the specified output serializer.
|
Copyright © 2009-2012 The Apache Software Foundation. All Rights Reserved.