backtype.storm.serialization
Class KryoTupleSerializer

java.lang.Object
  backtype.storm.serialization.KryoTupleSerializer

All Implemented Interfaces:

ITupleSerializer

public class KryoTupleSerializer
extends java.lang.Object
implements ITupleSerializer

Constructor Summary

KryoTupleSerializer(java.util.Map conf, TopologyContext context)

Method Summary

long	crc32(Tuple tuple)
byte[]	serialize(Tuple tuple)

Methods inherited from class java.lang.Object

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

Constructor Detail

KryoTupleSerializer

public KryoTupleSerializer(java.util.Map conf,
                           TopologyContext context)

Method Detail

serialize

public byte[] serialize(Tuple tuple)

Specified by:

serialize in interface ITupleSerializer

crc32

public long crc32(Tuple tuple)

Specified by:

crc32 in interface ITupleSerializer