Package org.apache.flink.changelog.fs
Interface StateChangeUploader
-
- All Superinterfaces:
AutoCloseable
- All Known Implementing Classes:
AbstractStateChangeFsUploader,DuplicatingStateChangeFsUploader,StateChangeFsUploader
@Internal public interface StateChangeUploader extends AutoCloseable
The purpose of this interface is to abstract the different implementations of uploading state changelog parts. It has a singleupload(java.util.Collection<org.apache.flink.changelog.fs.StateChangeUploadScheduler.UploadTask>)method with a collection ofStateChangeUploadScheduler.UploadTaskargument which is meant to initiate such an upload.
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static classStateChangeUploader.UploadTasksResultResult of executing one or moreupload tasks.
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description StateChangeUploader.UploadTasksResultupload(Collection<StateChangeUploadScheduler.UploadTask> tasks)Execute the upload task and return the results.-
Methods inherited from interface java.lang.AutoCloseable
close
-
-
-
-
Method Detail
-
upload
StateChangeUploader.UploadTasksResult upload(Collection<StateChangeUploadScheduler.UploadTask> tasks) throws IOException
Execute the upload task and return the results. It is the caller responsibility tocompletethe tasks.- Throws:
IOException
-
-