org.apache.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

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

Method Detail

getKryo

com.esotericsoftware.kryo.Kryo getKryo(Map<String,Object> conf)

preRegister

void preRegister(com.esotericsoftware.kryo.Kryo k,
                 Map<String,Object> conf)

postRegister

void postRegister(com.esotericsoftware.kryo.Kryo k,
                  Map<String,Object> conf)

postDecorate

void postDecorate(com.esotericsoftware.kryo.Kryo k,
                  Map<String,Object> conf)