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

        void registerStore​(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
      • getStore

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

        void flush()
      • checkpoint

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

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

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

        StateStore getGlobalStore​(java.lang.String name)