com.twitter.chill.hadoop

Class KryoDeserializer

java.lang.Object

com.twitter.chill.hadoop.KryoDeserializer

All Implemented Interfaces:

org.apache.hadoop.io.serializer.Deserializer<java.lang.Object>

public class KryoDeserializer
extends java.lang.Object
implements org.apache.hadoop.io.serializer.Deserializer<java.lang.Object>

Constructor Summary

Constructors

Constructor and Description
KryoDeserializer(com.twitter.chill.KryoPool kp, java.lang.Class<java.lang.Object> klass)

Method Summary

Modifier and Type	Method and Description
void	close()
java.lang.Object	deserialize(java.lang.Object o)
void	open(java.io.InputStream in)

Methods inherited from class java.lang.Object

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

Constructor Detail

KryoDeserializer

public KryoDeserializer(com.twitter.chill.KryoPool kp,
                        java.lang.Class<java.lang.Object> klass)

Method Detail

open

public void open(java.io.InputStream in)
          throws java.io.IOException

Specified by:

open in interface org.apache.hadoop.io.serializer.Deserializer<java.lang.Object>

Throws:

java.io.IOException

deserialize

public java.lang.Object deserialize(java.lang.Object o)
                             throws java.io.IOException

Specified by:

deserialize in interface org.apache.hadoop.io.serializer.Deserializer<java.lang.Object>

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Specified by:

close in interface org.apache.hadoop.io.serializer.Deserializer<java.lang.Object>

Throws:

java.io.IOException