org.expasy.mzjava.hadoop.io

Class AbstractAvroWritable<T>

java.lang.Object

org.expasy.mzjava.hadoop.io.AvroWritable

org.expasy.mzjava.hadoop.io.AbstractAvroWritable<T>

All Implemented Interfaces:

org.apache.hadoop.io.Writable

public abstract class AbstractAvroWritable<T>
extends AvroWritable

Serves as an adapter between Avro and Hadoop serialization.

Version:

sqrt -1

Author:

Oliver Horlacher

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractAvroWritable(AvroWriter<T> writer, AvroReader<T> reader)
protected	AbstractAvroWritable(T value, AvroWriter<T> writer, AvroReader<T> reader)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	avroRead(org.apache.avro.io.Decoder decoder)
protected void	avroWrite(org.apache.avro.io.Encoder encoder)
T	get()
void	set(T value)

Methods inherited from class org.expasy.mzjava.hadoop.io.AvroWritable

readFields, write

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AbstractAvroWritable

protected AbstractAvroWritable(AvroWriter<T> writer,
                    AvroReader<T> reader)

AbstractAvroWritable

protected AbstractAvroWritable(T value,
                    AvroWriter<T> writer,
                    AvroReader<T> reader)

Method Detail

avroWrite

protected void avroWrite(org.apache.avro.io.Encoder encoder)
                  throws IOException

Specified by:

avroWrite in class AvroWritable

Throws:

IOException

avroRead

protected void avroRead(org.apache.avro.io.Decoder decoder)
                 throws IOException

Specified by:

avroRead in class AvroWritable

Throws:

IOException

get

public T get()

set

public void set(T value)