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

      • reinitializeStateStoresForPartitions

        public void reinitializeStateStoresForPartitions​(java.util.Collection<org.apache.kafka.common.TopicPartition> partitions,
                                                         InternalProcessorContext processorContext)
      • 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​(java.util.Map<org.apache.kafka.common.TopicPartition,​java.lang.Long> offsets)
                   throws java.io.IOException
        Throws:
        java.io.IOException
      • checkpoint

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

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

        public void reinitializeStateStoresForPartitions​(org.slf4j.Logger log,
                                                         java.util.Map<java.lang.String,​StateStore> stateStores,
                                                         java.util.Map<java.lang.String,​java.lang.String> storeToChangelogTopic,
                                                         java.util.Collection<org.apache.kafka.common.TopicPartition> partitions,
                                                         InternalProcessorContext processorContext)