Package 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 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)