Class GlobalStateManagerImpl
- java.lang.Object
-
- org.apache.kafka.streams.processor.internals.GlobalStateManagerImpl
-
- All Implemented Interfaces:
GlobalStateManager
public class GlobalStateManagerImpl extends java.lang.Object implements GlobalStateManager
This class is responsible for the initialization, restoration, closing, flushing etc of Global State Stores. There is only ever 1 instance of this class per Application Instance.
-
-
Constructor Summary
Constructors Constructor Description GlobalStateManagerImpl(org.apache.kafka.common.utils.LogContext logContext, ProcessorTopology topology, org.apache.kafka.clients.consumer.Consumer<byte[],byte[]> globalConsumer, StateDirectory stateDirectory, StateRestoreListener stateRestoreListener, StreamsConfig config)
-
Method Summary
All Methods Instance Methods Concrete 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 globalProcessorContext)
Task.TaskType
taskType()
-
-
-
Constructor Detail
-
GlobalStateManagerImpl
public GlobalStateManagerImpl(org.apache.kafka.common.utils.LogContext logContext, ProcessorTopology topology, org.apache.kafka.clients.consumer.Consumer<byte[],byte[]> globalConsumer, StateDirectory stateDirectory, StateRestoreListener stateRestoreListener, StreamsConfig config)
-
-
Method Detail
-
setGlobalProcessorContext
public void setGlobalProcessorContext(InternalProcessorContext globalProcessorContext)
- Specified by:
setGlobalProcessorContext
in interfaceGlobalStateManager
-
initialize
public java.util.Set<java.lang.String> initialize()
- Specified by:
initialize
in interfaceGlobalStateManager
-
getGlobalStore
public StateStore getGlobalStore(java.lang.String name)
-
getStore
public StateStore getStore(java.lang.String name)
-
baseDir
public java.io.File baseDir()
-
registerStore
public void registerStore(StateStore store, StateRestoreCallback stateRestoreCallback)
-
flush
public void flush()
-
close
public void close() throws java.io.IOException
- Throws:
java.io.IOException
-
checkpoint
public void checkpoint(java.util.Map<org.apache.kafka.common.TopicPartition,java.lang.Long> offsets)
-
taskType
public Task.TaskType taskType()
-
changelogOffsets
public java.util.Map<org.apache.kafka.common.TopicPartition,java.lang.Long> changelogOffsets()
-
-