Package | Description |
---|---|
org.apache.flink.runtime.state.changelog |
Modifier and Type | Class and Description |
---|---|
static class |
SequenceNumber.GenericSequenceNumber
Generic
SequenceNumber . |
Modifier and Type | Method and Description |
---|---|
SequenceNumber |
StateChangelogWriter.lastAppendedSequenceNumber()
Get
SequenceNumber of the last element added by append . |
SequenceNumber |
SequenceNumber.next() |
SequenceNumber |
SequenceNumber.GenericSequenceNumber.next() |
static SequenceNumber |
SequenceNumber.of(long number) |
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.
|
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 this state changelog to free up resources.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.