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.
|
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 |
---|---|
Deserializer<AvroWrapper<T>> |
AvroSerialization.getDeserializer(Class<AvroWrapper<T>> c)
Gets an object capable of deserializing the output from a Mapper.
|
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 |
---|---|
Deserializer<AvroWrapper<T>> |
AvroSerialization.getDeserializer(Class<AvroWrapper<T>> c)
Gets an object capable of deserializing the output from a Mapper.
|
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 |
---|---|
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.