org.apache.gora.mapreduce

Class PersistentSerializer

java.lang.Object

org.apache.gora.mapreduce.PersistentSerializer

All Implemented Interfaces:

org.apache.hadoop.io.serializer.Serializer<Persistent>

public class PersistentSerializer
extends Object
implements org.apache.hadoop.io.serializer.Serializer<Persistent>

Hadoop serializer using Avro's SpecificDatumWriter with BinaryEncoder.

Constructor Summary

Constructors

Constructor and Description
PersistentSerializer()

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
void	open(OutputStream out) Open a connection for the OutputStream; should be called before serialization occurs.
void	serialize(Persistent persistent) Do the serialization of the Persistent object

Methods inherited from class java.lang.Object

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

Constructor Detail

PersistentSerializer

public PersistentSerializer()

Method Detail

close

public void close()
           throws IOException

Specified by:

close in interface org.apache.hadoop.io.serializer.Serializer<Persistent>

Throws:

IOException

open

public void open(OutputStream out)
          throws IOException

Open a connection for the OutputStream; should be called before serialization occurs. N.B. the close() should be called 'finally' after serialization is complete.

Specified by:

open in interface org.apache.hadoop.io.serializer.Serializer<Persistent>

Throws:

IOException

serialize

public void serialize(Persistent persistent)
               throws IOException

Do the serialization of the Persistent object

Specified by:

serialize in interface org.apache.hadoop.io.serializer.Serializer<Persistent>

Throws:

IOException