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, GeneralTopologyContext context)

Method Summary

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,
                           GeneralTopologyContext context)

Method Detail

serialize

public byte[] serialize(Tuple tuple)

Specified by:

serialize in interface ITupleSerializer