Package | Description |
---|---|
org.apache.flink.runtime.state.changelog | |
org.apache.flink.runtime.state.changelog.inmemory | |
org.apache.flink.state.changelog |
Modifier and Type | Class and Description |
---|---|
static class |
SequenceNumber.GenericSequenceNumber
Generic
SequenceNumber . |
Modifier and Type | Method and Description |
---|---|
SequenceNumber |
SequenceNumberRange.from()
Inclusive.
|
SequenceNumber |
SequenceNumberRange.GenericSequenceNumberRange.from() |
SequenceNumber |
StateChangelogWriter.getLowestSequenceNumber() |
SequenceNumber |
StateChangelogWriter.initialSequenceNumber()
Get the initial
SequenceNumber that is used for the first element. |
SequenceNumber |
SequenceNumber.next() |
SequenceNumber |
SequenceNumber.GenericSequenceNumber.next() |
SequenceNumber |
StateChangelogWriter.nextSequenceNumber()
Get
SequenceNumber to be used for the next element added by append . |
static SequenceNumber |
SequenceNumber.of(long number) |
SequenceNumber |
SequenceNumberRange.to()
Exclusive.
|
SequenceNumber |
SequenceNumberRange.GenericSequenceNumberRange.to() |
Modifier and Type | Method and Description |
---|---|
int |
SequenceNumber.GenericSequenceNumber.compareTo(SequenceNumber o) |
void |
StateChangelogWriter.confirm(SequenceNumber from,
SequenceNumber to)
Mark the given state changes as confirmed by the JM.
|
boolean |
SequenceNumberRange.contains(SequenceNumber sqn) |
boolean |
SequenceNumberRange.GenericSequenceNumberRange.contains(SequenceNumber sqn) |
static SequenceNumberRange |
SequenceNumberRange.generic(SequenceNumber from,
SequenceNumber to) |
CompletableFuture<Handle> |
StateChangelogWriter.persist(SequenceNumber from)
Durably persist previously
appended data starting from the
provided SequenceNumber and up to the latest change added. |
void |
StateChangelogWriter.reset(SequenceNumber from,
SequenceNumber to)
Reset the state the given state changes.
|
void |
StateChangelogWriter.truncate(SequenceNumber to)
Truncate in-memory view of this state changelog to free up resources.
|
Modifier and Type | Method and Description |
---|---|
static InMemoryChangelogStateHandle |
InMemoryChangelogStateHandle.restore(List<StateChange> changes,
SequenceNumber from,
SequenceNumber to,
KeyGroupRange keyGroupRange,
StateHandleID stateHandleId) |
Constructor and Description |
---|
InMemoryChangelogStateHandle(List<StateChange> changes,
SequenceNumber from,
SequenceNumber to,
KeyGroupRange keyGroupRange) |
Modifier and Type | Method and Description |
---|---|
void |
ChangelogKeyedStateBackend.updateChangelogSnapshotState(SnapshotResult<KeyedStateHandle> materializedSnapshot,
long materializationID,
SequenceNumber upTo)
This method is not thread safe.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.