public interface GlobalStateManager
Modifier and Type | Method and Description |
---|---|
java.io.File |
baseDir() |
void |
checkpoint(java.util.Map<org.apache.kafka.common.TopicPartition,java.lang.Long> offsets) |
java.util.Map<org.apache.kafka.common.TopicPartition,java.lang.Long> |
checkpointed() |
void |
close(java.util.Map<org.apache.kafka.common.TopicPartition,java.lang.Long> offsets) |
void |
flush() |
StateStore |
getGlobalStore(java.lang.String name) |
StateStore |
getStore(java.lang.String name) |
java.util.Set<java.lang.String> |
initialize() |
void |
register(StateStore store,
StateRestoreCallback stateRestoreCallback) |
void |
reinitializeStateStoresForPartitions(java.util.Collection<org.apache.kafka.common.TopicPartition> partitions,
InternalProcessorContext processorContext) |
void |
setGlobalProcessorContext(InternalProcessorContext processorContext) |
void setGlobalProcessorContext(InternalProcessorContext processorContext)
java.util.Set<java.lang.String> initialize()
java.lang.IllegalStateException
- If store gets registered after initialized is already finishedStreamsException
- if the store's change log does not contain the partitionjava.io.File baseDir()
void register(StateStore store, StateRestoreCallback stateRestoreCallback)
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 partitionvoid flush()
void reinitializeStateStoresForPartitions(java.util.Collection<org.apache.kafka.common.TopicPartition> partitions, InternalProcessorContext processorContext)
void close(java.util.Map<org.apache.kafka.common.TopicPartition,java.lang.Long> offsets) throws java.io.IOException
java.io.IOException
StateStore getGlobalStore(java.lang.String name)
StateStore getStore(java.lang.String name)
void checkpoint(java.util.Map<org.apache.kafka.common.TopicPartition,java.lang.Long> offsets)
java.util.Map<org.apache.kafka.common.TopicPartition,java.lang.Long> checkpointed()