Skip to content

StateManager

StateManager is an abstraction of state managers.

Contract

baseDir

File baseDir()

Used when:

  • AbstractProcessorContext is requested for the stateDir
  • GlobalStateUpdateTask is requested to close
  • StateManagerUtil is requested to closeStateManager

changelogFor

String changelogFor(
  String storeName)

Used when:

changelogOffsets

Map<TopicPartition, Long> changelogOffsets()

Used when:

checkpoint

void checkpoint()

Used when:

close

void close()

Used when:

flush

void flush()

Used when:

getGlobalStore

StateStore getGlobalStore(
  String name)

Used when:

getStore

StateStore getStore(
  String name)

Used when:

registerStore

void registerStore(
  StateStore store,
  StateRestoreCallback stateRestoreCallback)

Used when:

  • AbstractProcessorContext is requested to register

taskType

TaskType taskType()

updateChangelogOffsets

void updateChangelogOffsets(
  Map<TopicPartition, Long> writtenOffsets)

Used when:

Implementations

Back to top