org.apache.gora.mapreduce

Class PersistentDeserializer

java.lang.Object

org.apache.gora.mapreduce.PersistentDeserializer

All Implemented Interfaces:

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

public class PersistentDeserializer
extends Object
implements org.apache.hadoop.io.serializer.Deserializer<Persistent>

Hadoop deserializer using SpecificDatumReader with BinaryDecoder.

Constructor Summary

Constructors

Constructor and Description
PersistentDeserializer(Class<? extends Persistent> c, boolean reuseObjects)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
Persistent	deserialize(Persistent persistent)
void	open(InputStream in)

Methods inherited from class java.lang.Object

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

Constructor Detail

PersistentDeserializer

public PersistentDeserializer(Class<? extends Persistent> c,
                      boolean reuseObjects)

Method Detail

open

public void open(InputStream in)
          throws IOException

Specified by:

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

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

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

Throws:

IOException

deserialize

public Persistent deserialize(Persistent persistent)
                       throws IOException

Specified by:

deserialize in interface org.apache.hadoop.io.serializer.Deserializer<Persistent>

Throws:

IOException