Package | Description |
---|---|
org.apache.flink.runtime.state.changelog | |
org.apache.flink.runtime.state.changelog.inmemory |
Class and Description |
---|
SequenceNumber
A logical timestamp to draw a boundary between the materialized and non-materialized changes.
|
StateChange
Change of state of a keyed operator.
|
StateChangelogHandle
A handle to saved
state changes . |
StateChangelogHandleStreamImpl.StateChangeStreamReader |
StateChangelogWriter
Allows to write data to the log.
|
StateChangelogWriterFactory
StateChangelogWriter factory. |
Class and Description |
---|
StateChangelogWriterFactory
StateChangelogWriter factory. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.