Class GlobalStateManagerImpl

  • All Implemented Interfaces:
    GlobalStateManager

    public class GlobalStateManagerImpl
    extends java.lang.Object
    implements GlobalStateManager
    This class is responsible for the initialization, restoration, closing, flushing etc of Global State Stores. There is only ever 1 instance of this class per Application Instance.
    • Constructor Detail

    • Method Detail

      • getGlobalStore

        public StateStore getGlobalStore​(java.lang.String name)
      • getStore

        public StateStore getStore​(java.lang.String name)
      • baseDir

        public java.io.File baseDir()
      • flush

        public void flush()
      • close

        public void close()
                   throws java.io.IOException
        Throws:
        java.io.IOException
      • checkpoint

        public void checkpoint​(java.util.Map<org.apache.kafka.common.TopicPartition,​java.lang.Long> offsets)
      • changelogOffsets

        public java.util.Map<org.apache.kafka.common.TopicPartition,​java.lang.Long> changelogOffsets()