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()
java.util.Map<org.apache.kafka.common.TopicPartition,java.lang.Long>
changelogOffsets()
void
checkpoint(java.util.Map<org.apache.kafka.common.TopicPartition,java.lang.Long> offsets)
void
close()
void
flush()
StateStore
getGlobalStore(java.lang.String name)
StateStore
getStore(java.lang.String name)
java.util.Set<java.lang.String>
initialize()
void
registerStore(StateStore store, StateRestoreCallback stateRestoreCallback)
void
setGlobalProcessorContext(InternalProcessorContext processorContext)
Task.TaskType
taskType()
-
-
-
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()
-
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
-
taskType
Task.TaskType taskType()
-
getGlobalStore
StateStore getGlobalStore(java.lang.String name)
-
-