GlobalStateManagerImpl

GlobalStateManagerImpl is a concrete GlobalStateManager (and a AbstractStateManager) that…​FIXME

GlobalStateManagerImpl is created exclusively when GlobalStreamThread is requested to initialize (when GlobalStreamThread is started with KafkaStreams).

initialize Method

Set<String> initialize()
Note
 initialize is part of GlobalStateManager Contract to…​FIXME.

initialize…​FIXME

checkpoint Method

void checkpoint(final Map<TopicPartition, Long> offsets)
Note
 checkpoint is part of Checkpointable Contract to…​FIXME.

checkpoint…​FIXME

Creating GlobalStateManagerImpl Instance

GlobalStateManagerImpl takes the following when created:

GlobalStateManagerImpl initializes the internal registries and counters.

reinitializeStateStoresForPartitions Method

void reinitializeStateStoresForPartitions(
  final Collection<TopicPartition> partitions,
  final InternalProcessorContext processorContext)
Note
 reinitializeStateStoresForPartitions is part of StateManager Contract to…​FIXME.

reinitializeStateStoresForPartitions…​FIXME

Flushing All State Stores — flush Method

void flush()
Note
 flush is part of the StateManager Contract to flush all state stores registered with the state manager.

flush…​FIXME

restoreState Internal Method

void restoreState(
  StateRestoreCallback stateRestoreCallback,
  List<TopicPartition> topicPartitions,
  Map<TopicPartition, Long> highWatermarks,
  String storeName)

restoreState…​FIXME

Note
 restoreState is used exclusively when GlobalStateManagerImpl is requested to register a state store.

Registering State Store — register Method

void register(
  final StateStore store,
  final StateRestoreCallback stateRestoreCallback)
Note
 register is part of the StateManager Contract to register a state store.

register…​FIXME

Closing State Manager — close Method

void close(final Map<TopicPartition, Long> offsets) throws IOException
Note
 close is part of the StateManager Contract to close the state manager.

close…​FIXME

results matching ""

    No results matching ""