GlobalStateManager (kafka 2.6.1.100-eep-810 API)

All Known Implementing Classes:

GlobalStateManagerImpl
```
public interface GlobalStateManager
```

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`File`	`baseDir()`
`Map<TopicPartition,Long>`	`changelogOffsets()`
`void`	`checkpoint(Map<TopicPartition,Long> offsets)`
`void`	`close()`
`void`	`flush()`
`StateStore`	`getGlobalStore(String name)`
`StateStore`	`getStore(String name)`
`Set<String>`	`initialize()`
`void`	`registerStore(StateStore store, StateRestoreCallback stateRestoreCallback)`
`void`	`setGlobalProcessorContext(InternalProcessorContext processorContext)`
`Task.TaskType`	`taskType()`

- Method Detail
  - setGlobalProcessorContext
```
void setGlobalProcessorContext(InternalProcessorContext processorContext)
```
  - initialize
```
Set<String> initialize()
```
    Throws:
    
    IllegalStateException - If store gets registered after initialized is already finished
    
    StreamsException - if the store's change log does not contain the partition
  - baseDir
```
File baseDir()
```
  - registerStore
```
void registerStore(StateStore store,
                   StateRestoreCallback stateRestoreCallback)
```
    Throws:
    
    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(String name)
```
  - flush
```
void flush()
```
  - checkpoint
```
void checkpoint(Map<TopicPartition,Long> offsets)
```
  - changelogOffsets
```
Map<TopicPartition,Long> changelogOffsets()
```
  - close
```
void close()
    throws IOException
```
    Throws:
    
    IOException
  - taskType
```
Task.TaskType taskType()
```
  - getGlobalStore
```
StateStore getGlobalStore(String name)
```