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 Details

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