backtype.storm.serialization

Class KryoTupleSerializer

java.lang.Object

backtype.storm.serialization.KryoTupleSerializer

All Implemented Interfaces:

ITupleSerializer

public class KryoTupleSerializer
extends Object
implements ITupleSerializer

Constructor Summary

Constructors

Constructor and Description
KryoTupleSerializer(Map conf, GeneralTopologyContext context)

Method Summary

Methods

Modifier and Type	Method and Description
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(Map conf,
                   GeneralTopologyContext context)

Method Detail

serialize

public byte[] serialize(Tuple tuple)

Specified by:

serialize in interface ITupleSerializer