Package | Description |
---|---|
org.apache.flink.changelog.fs |
Modifier and Type | Method and Description |
---|---|
static UploadResult |
UploadResult.of(StreamStateHandle handle,
StreamStateHandle localHandle,
StateChangeSet changeSet,
long offset,
long localOffset) |
Modifier and Type | Method and Description |
---|---|
void |
StateChangeUploadScheduler.UploadTask.complete(List<UploadResult> results) |
Constructor and Description |
---|
UploadTask(Collection<StateChangeSet> changeSets,
java.util.function.Consumer<List<UploadResult>> successCallback,
java.util.function.BiConsumer<List<SequenceNumber>,Throwable> failureCallback) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.