Interface GlobalStateManager

    • Method Detail

      • initialize

        java.util.Set<java.lang.String> initialize()
        Throws:
        java.lang.IllegalStateException - If store gets registered after initialized is already finished
        StreamsException - if the store's change log does not contain the partition
      • baseDir

        java.io.File baseDir()
      • register

        void register​(StateStore store,
                      StateRestoreCallback stateRestoreCallback)
        Throws:
        java.lang.IllegalArgumentException - if the store name has already been registered or if it is not a valid name (e.g., when it conflicts with the names of internal topics, like the checkpoint file name)
        StreamsException - if the store's change log does not contain the partition
      • flush

        void flush()
      • reinitializeStateStoresForPartitions

        void reinitializeStateStoresForPartitions​(java.util.Collection<org.apache.kafka.common.TopicPartition> partitions,
                                                  InternalProcessorContext processorContext)
      • close

        void close​(java.util.Map<org.apache.kafka.common.TopicPartition,​java.lang.Long> offsets)
            throws java.io.IOException
        Throws:
        java.io.IOException
      • getGlobalStore

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

        StateStore getStore​(java.lang.String name)
      • checkpoint

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

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