Uses of Interface
org.apache.flink.changelog.fs.StateChangeUploader
-
-
Uses of StateChangeUploader in org.apache.flink.changelog.fs
Classes in org.apache.flink.changelog.fs that implement StateChangeUploader Modifier and Type Class Description classAbstractStateChangeFsUploaderBase implementation of StateChangeUploader.classDuplicatingStateChangeFsUploaderA StateChangeFsUploader implementation that writes the changes to remote and local.classStateChangeFsUploaderA synchronousStateChangeUploadSchedulerimplementation that uploads the changes usingFileSystem.Methods in org.apache.flink.changelog.fs with parameters of type StateChangeUploader Modifier and Type Method Description static StateChangeUploadSchedulerStateChangeUploadScheduler. directScheduler(StateChangeUploader uploader)
-