com.twitter.chill.protobuf

Class ProtobufSerializer

java.lang.Object

com.esotericsoftware.kryo.Serializer<com.google.protobuf.Message>

com.twitter.chill.protobuf.ProtobufSerializer

public class ProtobufSerializer
extends com.esotericsoftware.kryo.Serializer<com.google.protobuf.Message>

Kryo serializer for Protobuf instances. Note that this class is not thread-safe. (Kryo itself is not thread safe, so this shouldn't be a concern.) Use this with addDefaultSerializer(Message.class, ProtobufSerializer.class) It still helps to .register your instances so the full class name does not need to be written.

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.HashMap<java.lang.Class,java.lang.reflect.Method>	methodCache

Constructor Summary

Constructors

Constructor and Description
ProtobufSerializer()

Method Summary

Methods

Modifier and Type	Method and Description
protected java.lang.reflect.Method	getParse(java.lang.Class cls) This is slow, so we should cache to avoid killing perf: See: http://www.jguru.com/faq/view.jsp?EID=246569
com.google.protobuf.Message	read(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Input input, java.lang.Class<com.google.protobuf.Message> pbClass)
void	write(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Output output, com.google.protobuf.Message mes)

Methods inherited from class com.esotericsoftware.kryo.Serializer

copy, getAcceptsNull, isImmutable, setAcceptsNull, setGenerics, setImmutable

Methods inherited from class java.lang.Object

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

Field Detail

methodCache

protected final java.util.HashMap<java.lang.Class,java.lang.reflect.Method> methodCache

Constructor Detail

ProtobufSerializer

public ProtobufSerializer()

Method Detail

getParse

protected java.lang.reflect.Method getParse(java.lang.Class cls)
                                     throws java.lang.Exception

This is slow, so we should cache to avoid killing perf: See: http://www.jguru.com/faq/view.jsp?EID=246569

Throws:

java.lang.Exception

write

public void write(com.esotericsoftware.kryo.Kryo kryo,
         com.esotericsoftware.kryo.io.Output output,
         com.google.protobuf.Message mes)

Specified by:

write in class com.esotericsoftware.kryo.Serializer<com.google.protobuf.Message>

read

public com.google.protobuf.Message read(com.esotericsoftware.kryo.Kryo kryo,
                               com.esotericsoftware.kryo.io.Input input,
                               java.lang.Class<com.google.protobuf.Message> pbClass)

Specified by:

read in class com.esotericsoftware.kryo.Serializer<com.google.protobuf.Message>