public class KryoSerializer
extends java.lang.Object
implements org.apache.hadoop.io.serializer.Serializer<java.lang.Object>
| Constructor and Description |
|---|
KryoSerializer(com.twitter.chill.KryoPool kp) |
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
void |
open(java.io.OutputStream out) |
void |
serialize(java.lang.Object o) |
public void open(java.io.OutputStream out)
throws java.io.IOException
open in interface org.apache.hadoop.io.serializer.Serializer<java.lang.Object>java.io.IOExceptionpublic void serialize(java.lang.Object o)
throws java.io.IOException
serialize in interface org.apache.hadoop.io.serializer.Serializer<java.lang.Object>java.io.IOExceptionpublic void close()
throws java.io.IOException
close in interface org.apache.hadoop.io.serializer.Serializer<java.lang.Object>java.io.IOException