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<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.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.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–2020 The Apache Software Foundation. All rights reserved.