public class GlobalStateManagerImpl extends java.lang.Object implements GlobalStateManager
Constructor and 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) |
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 |
reinitializeStateStoresForPartitions(org.slf4j.Logger log,
java.util.Map<java.lang.String,StateStore> stateStores,
java.util.Map<java.lang.String,java.lang.String> storeToChangelogTopic,
java.util.Collection<org.apache.kafka.common.TopicPartition> partitions,
InternalProcessorContext processorContext) |
void |
setGlobalProcessorContext(InternalProcessorContext processorContext) |
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)
public void setGlobalProcessorContext(InternalProcessorContext processorContext)
setGlobalProcessorContext
in interface GlobalStateManager
public java.util.Set<java.lang.String> initialize()
initialize
in interface GlobalStateManager
public void reinitializeStateStoresForPartitions(java.util.Collection<org.apache.kafka.common.TopicPartition> partitions, InternalProcessorContext processorContext)
public StateStore getGlobalStore(java.lang.String name)
public StateStore getStore(java.lang.String name)
public java.io.File baseDir()
public void register(StateStore store, StateRestoreCallback stateRestoreCallback)
public void flush()
public void close(java.util.Map<org.apache.kafka.common.TopicPartition,java.lang.Long> offsets) throws java.io.IOException
java.io.IOException
public void checkpoint(java.util.Map<org.apache.kafka.common.TopicPartition,java.lang.Long> offsets)
public java.util.Map<org.apache.kafka.common.TopicPartition,java.lang.Long> checkpointed()
public void reinitializeStateStoresForPartitions(org.slf4j.Logger log, java.util.Map<java.lang.String,StateStore> stateStores, java.util.Map<java.lang.String,java.lang.String> storeToChangelogTopic, java.util.Collection<org.apache.kafka.common.TopicPartition> partitions, InternalProcessorContext processorContext)