Uses of Class
org.apache.avro.mapred.AvroWrapper
Package
Description
Run Hadoop MapReduce jobs over
Avro data, with map and reduce functions written in Java.
Read and write Avro data
in Trevni column files.
-
Uses of AvroWrapper in org.apache.avro.hadoop.io
Modifier and TypeClassDescriptionclass
AvroDeserializer<T extends AvroWrapper<D>,
D> Deserializes AvroWrapper objects within Hadoop.Modifier and TypeMethodDescriptionprotected AvroWrapper
<D> AvroKeyDeserializer.createAvroWrapper()
Creates a new emptyAvroKey
instance.protected AvroWrapper
<D> AvroValueDeserializer.createAvroWrapper()
Creates a new emptyAvroValue
instance.Modifier and TypeMethodDescriptionAvroSerialization.getDeserializer
(Class<AvroWrapper<T>> c) Gets an object capable of deserializing the output from a Mapper.AvroSerialization.getSerializer
(Class<AvroWrapper<T>> c) Gets an object capable of serializing output from a Mapper.Modifier and TypeMethodDescriptionAvroDatumConverterFactory.AvroWrapperConverter.convert
(AvroWrapper<?> input) void
AvroSerializer.serialize
(AvroWrapper<T> avroWrapper) Modifier and TypeMethodDescriptionAvroSerialization.getDeserializer
(Class<AvroWrapper<T>> c) Gets an object capable of deserializing the output from a Mapper.AvroSerialization.getSerializer
(Class<AvroWrapper<T>> c) Gets an object capable of serializing output from a Mapper. -
Uses of AvroWrapper in org.apache.avro.mapred
Modifier and TypeClassDescriptionclass
AvroKey<T>
The wrapper of keys for jobs configured withAvroJob
.class
AvroValue<T>
The wrapper of values for jobs configured withAvroJob
.Modifier and TypeMethodDescriptionAvroSerialization.getDeserializer
(Class<AvroWrapper<T>> c) Returns the specified map output deserializer.AvroInputFormat.getRecordReader
(InputSplit split, JobConf job, Reporter reporter) AvroUtf8InputFormat.getRecordReader
(InputSplit split, JobConf job, Reporter reporter) SequenceFileInputFormat.getRecordReader
(InputSplit split, JobConf job, Reporter reporter) AvroOutputFormat.getRecordWriter
(FileSystem ignore, JobConf job, String name, Progressable prog) AvroSerialization.getSerializer
(Class<AvroWrapper<T>> c) Returns the specified output serializer.Modifier and TypeMethodDescriptionint
AvroKeyComparator.compare
(AvroWrapper<T> x, AvroWrapper<T> y) boolean
AvroRecordReader.next
(AvroWrapper<T> wrapper, NullWritable ignore) Modifier and TypeMethodDescriptionAvroSerialization.getDeserializer
(Class<AvroWrapper<T>> c) Returns the specified map output deserializer.AvroSerialization.getSerializer
(Class<AvroWrapper<T>> c) Returns the specified output serializer. -
Uses of AvroWrapper in org.apache.trevni.avro
Modifier and TypeMethodDescriptionAvroTrevniInputFormat.getRecordReader
(InputSplit split, JobConf job, Reporter reporter) AvroTrevniOutputFormat.getRecordWriter
(FileSystem ignore, JobConf job, String name, Progressable prog)