public class KryoDeserializer
extends java.lang.Object
implements org.apache.hadoop.io.serializer.Deserializer<java.lang.Object>
| Constructor and Description |
|---|
KryoDeserializer(com.twitter.chill.KryoPool kp,
java.lang.Class<java.lang.Object> klass) |
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
java.lang.Object |
deserialize(java.lang.Object o) |
void |
open(java.io.InputStream in) |
public KryoDeserializer(com.twitter.chill.KryoPool kp,
java.lang.Class<java.lang.Object> klass)
public void open(java.io.InputStream in)
throws java.io.IOException
open in interface org.apache.hadoop.io.serializer.Deserializer<java.lang.Object>java.io.IOExceptionpublic java.lang.Object deserialize(java.lang.Object o)
throws java.io.IOException
deserialize in interface org.apache.hadoop.io.serializer.Deserializer<java.lang.Object>java.io.IOExceptionpublic void close()
throws java.io.IOException
close in interface org.apache.hadoop.io.serializer.Deserializer<java.lang.Object>java.io.IOException