Package org.apache.flink.changelog.fs
Interface StateChangeUploadScheduler
-
- All Superinterfaces:
AutoCloseable
@Internal public interface StateChangeUploadScheduler extends AutoCloseable
Schedulesupload tasks
on aStateChangeUploader
. In the simplest form, directly callsStateChangeUploader.upload(Collection)
. Other implementations might batch the tasks for efficiency.
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static class
StateChangeUploadScheduler.UploadTask
Upload Task forStateChangeUploadScheduler
.
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description static StateChangeUploadScheduler
directScheduler(StateChangeUploader uploader)
static StateChangeUploadScheduler
fromConfig(JobID jobID, ReadableConfig config, ChangelogStorageMetricGroup metricGroup, TaskChangelogRegistry changelogRegistry, LocalRecoveryConfig localRecoveryConfig)
default AvailabilityProvider
getAvailabilityProvider()
void
upload(StateChangeUploadScheduler.UploadTask uploadTask)
-
Methods inherited from interface java.lang.AutoCloseable
close
-
-
-
-
Method Detail
-
upload
void upload(StateChangeUploadScheduler.UploadTask uploadTask) throws IOException
- Throws:
IOException
-
directScheduler
static StateChangeUploadScheduler directScheduler(StateChangeUploader uploader)
-
fromConfig
static StateChangeUploadScheduler fromConfig(JobID jobID, ReadableConfig config, ChangelogStorageMetricGroup metricGroup, TaskChangelogRegistry changelogRegistry, LocalRecoveryConfig localRecoveryConfig) throws IOException
- Throws:
IOException
-
getAvailabilityProvider
default AvailabilityProvider getAvailabilityProvider()
-
-