Interface | Description |
---|---|
SequenceNumber |
A logical timestamp to draw a boundary between the materialized and non-materialized changes.
|
StateChangelogHandle<ReaderContext> |
A handle to saved
state changes . |
StateChangelogHandleStreamImpl.StateChangeStreamReader | |
StateChangelogWriter<Handle extends StateChangelogHandle<?>> |
Allows to write data to the log.
|
StateChangelogWriterFactory<Handle extends StateChangelogHandle<?>> |
StateChangelogWriter factory. |
Class | Description |
---|---|
SequenceNumber.GenericSequenceNumber |
Generic
SequenceNumber . |
StateChange |
Change of state of a keyed operator.
|
StateChangelogHandleStreamImpl |
StateChangelogHandle implementation based on StreamStateHandle . |
StateChangelogWriterFactoryLoader |
A thin wrapper around
PluginManager to load StateChangelogWriterFactory . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.