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