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

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

Method Detail

getKryo

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

preRegister

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

postRegister

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

postDecorate

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