backtype.storm.serialization

Interface IKryoFactory

All Known Implementing Classes:

DefaultKryoFactory

public interface IKryoFactory

An interface that controls the Kryo instance used by Storm for serialization. The lifecycle is: 1. The Kryo instance is constructed using getKryo 2. Storm registers the default classes (e.g. arrays, lists, maps, etc.) 3. Storm calls preRegister hook 4. Storm registers all user-defined registrations through topology.kryo.register 5. Storm calls postRegister hook 6. Storm calls all user-defined decorators through topology.kryo.decorators 7. Storm calls postDecorate hook

Method Summary

Methods

Modifier and Type	Method and Description
com.esotericsoftware.kryo.Kryo	getKryo(Map conf)
void	postDecorate(com.esotericsoftware.kryo.Kryo k, Map conf)
void	postRegister(com.esotericsoftware.kryo.Kryo k, Map conf)
void	preRegister(com.esotericsoftware.kryo.Kryo k, Map conf)

Method Detail

getKryo

com.esotericsoftware.kryo.Kryo getKryo(Map conf)

preRegister

void preRegister(com.esotericsoftware.kryo.Kryo k,
               Map conf)

postRegister

void postRegister(com.esotericsoftware.kryo.Kryo k,
                Map conf)

postDecorate

void postDecorate(com.esotericsoftware.kryo.Kryo k,
                Map conf)