This project has retired. For details please refer to its Attic page.

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 PersistentDatumReader with BinaryDecoder.

Constructor Summary

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

Method Summary

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