Interface GlobalStateManager
-
- All Known Implementing Classes:
GlobalStateManagerImpl
public interface GlobalStateManager
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method 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)
-
-
-
Method Detail
-
setGlobalProcessorContext
void setGlobalProcessorContext(InternalProcessorContext processorContext)
-
initialize
java.util.Set<java.lang.String> initialize()
- Throws:
java.lang.IllegalStateException
- If store gets registered after initialized is already finishedStreamsException
- 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()
-
-