public static final class StateChangeUploader.UploadTasksResult extends Object
upload tasks
.Constructor and Description |
---|
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) |
Modifier and Type | Method and Description |
---|---|
void |
complete() |
void |
discard() |
long |
getStateSize() |
StreamStateHandle |
getStreamStateHandle() |
public UploadTasksResult(Map<StateChangeUploadScheduler.UploadTask,Map<StateChangeSet,Tuple2<Long,Long>>> tasksOffsets, StreamStateHandle handle)
public UploadTasksResult(Map<StateChangeUploadScheduler.UploadTask,Map<StateChangeSet,Tuple2<Long,Long>>> tasksOffsets, StreamStateHandle handle, @Nullable StreamStateHandle localHandle)
public void complete()
public long getStateSize()
@VisibleForTesting public StreamStateHandle getStreamStateHandle()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.