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.