Modifier and Type | Field and Description |
---|---|
SequenceNumber |
UploadResult.sequenceNumber |
Modifier and Type | Method and Description |
---|---|
SequenceNumber |
UploadResult.getSequenceNumber() |
SequenceNumber |
StateChangeSet.getSequenceNumber() |
Constructor and Description |
---|
StateChangeSet(UUID logId,
SequenceNumber sequenceNumber,
List<StateChange> changes) |
UploadResult(StreamStateHandle streamStateHandle,
long offset,
SequenceNumber sequenceNumber,
long size) |
UploadResult(StreamStateHandle streamStateHandle,
StreamStateHandle localStreamHandle,
long offset,
long localOffset,
SequenceNumber sequenceNumber,
long size) |
Constructor and Description |
---|
UploadTask(Collection<StateChangeSet> changeSets,
java.util.function.Consumer<List<UploadResult>> successCallback,
java.util.function.BiConsumer<List<SequenceNumber>,Throwable> failureCallback) |
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.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,
long checkpointId)
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<SnapshotResult<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,
long checkpointId)
Reset the state the given state changes.
|
void |
StateChangelogWriter.truncate(SequenceNumber to)
Truncate this state changelog to free up the resources and collect any garbage.
|
void |
StateChangelogWriter.truncateAndClose(SequenceNumber from)
Truncate the tail of log and close it.
|
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.handleMaterializationResult(SnapshotResult<KeyedStateHandle> materializedSnapshot,
long materializationID,
SequenceNumber upTo)
This method is not thread safe.
|
Modifier and Type | Method and Description |
---|---|
void |
PeriodicMaterializationManager.MaterializationTarget.handleMaterializationResult(SnapshotResult<KeyedStateHandle> materializedSnapshot,
long materializationID,
SequenceNumber upTo)
This method is not thread safe.
|
Constructor and Description |
---|
MaterializationRunnable(RunnableFuture<SnapshotResult<KeyedStateHandle>> materializationRunnable,
long materializationID,
SequenceNumber materializedTo) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.