Class and Description |
---|
ChangelogStateHandleStreamImpl
ChangelogStateHandle implementation based on StreamStateHandle . |
SequenceNumber
A logical timestamp to draw a boundary between the materialized and non-materialized changes.
|
StateChange
Change of state of a keyed operator.
|
StateChangelogHandleReader
Allows to read state changelog referenced by the provided
ChangelogStateHandle . |
StateChangelogStorage
A storage for changelog.
|
StateChangelogStorageFactory
A factory for
StateChangelogStorage . |
StateChangelogStorageView
A storage view for changelog.
|
Class and Description |
---|
ChangelogStateHandle
A handle to saved
state changes . |
StateChangelogStorage
A storage for changelog.
|
StateChangelogStorageView
A storage view for changelog.
|
Class and Description |
---|
ChangelogStateBackendHandle
A handle to ChangelogStateBackend state.
|
ChangelogStateBackendHandle.ChangelogStateBackendHandleImpl |
ChangelogStateHandle
A handle to saved
state changes . |
ChangelogStateHandleStreamImpl
ChangelogStateHandle implementation based on StreamStateHandle . |
LocalChangelogRegistry
This registry is responsible for deleting changlog's local handles which are not in use.
|
SequenceNumber
A logical timestamp to draw a boundary between the materialized and non-materialized changes.
|
SequenceNumber.GenericSequenceNumber
Generic
SequenceNumber . |
SequenceNumberRange |
StateChange
Change of state of a keyed operator.
|
StateChangelogHandleReader
Allows to read state changelog referenced by the provided
ChangelogStateHandle . |
StateChangelogHandleStreamHandleReader.StateChangeIterator
Reads a stream of state changes starting from a specified offset.
|
StateChangelogStorage
A storage for changelog.
|
StateChangelogStorageView
A storage view for changelog.
|
StateChangelogWriter
Allows to write data to the log.
|
Class and Description |
---|
ChangelogStateHandle
A handle to saved
state changes . |
SequenceNumber
A logical timestamp to draw a boundary between the materialized and non-materialized changes.
|
StateChange
Change of state of a keyed operator.
|
StateChangelogHandleReader
Allows to read state changelog referenced by the provided
ChangelogStateHandle . |
StateChangelogStorage
A storage for changelog.
|
StateChangelogStorageFactory
A factory for
StateChangelogStorage . |
StateChangelogStorageView
A storage view for changelog.
|
Class and Description |
---|
ChangelogStateBackendHandle
A handle to ChangelogStateBackend state.
|
ChangelogStateHandle
A handle to saved
state changes . |
SequenceNumber
A logical timestamp to draw a boundary between the materialized and non-materialized changes.
|
StateChangelogWriter
Allows to write data to the log.
|
Class and Description |
---|
ChangelogStateBackendHandle
A handle to ChangelogStateBackend state.
|
Class and Description |
---|
SequenceNumber
A logical timestamp to draw a boundary between the materialized and non-materialized changes.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.