Package org.apache.flink.changelog.fs
Class StateChangeUploadScheduler.UploadTask
- java.lang.Object
-
- org.apache.flink.changelog.fs.StateChangeUploadScheduler.UploadTask
-
- Enclosing interface:
- StateChangeUploadScheduler
@ThreadSafe public static final class StateChangeUploadScheduler.UploadTask extends Object
Upload Task forStateChangeUploadScheduler.
-
-
Constructor Summary
Constructors Constructor Description UploadTask(Collection<StateChangeSet> changeSets, java.util.function.Consumer<List<UploadResult>> successCallback, java.util.function.BiConsumer<List<org.apache.flink.runtime.state.changelog.SequenceNumber>,Throwable> failureCallback)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidcomplete(List<UploadResult> results)voidfail(Throwable error)Collection<StateChangeSet>getChangeSets()longgetSize()booleanisFinished()StringtoString()
-
-
-
Constructor Detail
-
UploadTask
public UploadTask(Collection<StateChangeSet> changeSets, java.util.function.Consumer<List<UploadResult>> successCallback, java.util.function.BiConsumer<List<org.apache.flink.runtime.state.changelog.SequenceNumber>,Throwable> failureCallback)
-
-
Method Detail
-
complete
public void complete(List<UploadResult> results)
-
fail
public void fail(Throwable error)
-
getSize
public long getSize()
-
getChangeSets
public Collection<StateChangeSet> getChangeSets()
-
isFinished
public boolean isFinished()
-
-