Class GlobalStateUpdateTask


  • public class GlobalStateUpdateTask
    extends java.lang.Object
    Updates the state for all Global State Stores.
    • Method Detail

      • initialize

        public java.util.Map<org.apache.kafka.common.TopicPartition,​java.lang.Long> 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
      • update

        public void update​(org.apache.kafka.clients.consumer.ConsumerRecord<byte[],​byte[]> record)
      • flushState

        public void flushState()
      • close

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