Uses of Interface
org.apache.flink.changelog.fs.TaskChangelogRegistry
-
-
Uses of TaskChangelogRegistry in org.apache.flink.changelog.fs
Fields in org.apache.flink.changelog.fs declared as TaskChangelogRegistry Modifier and Type Field Description static TaskChangelogRegistryTaskChangelogRegistry. NO_OPMethods in org.apache.flink.changelog.fs that return TaskChangelogRegistry Modifier and Type Method Description static TaskChangelogRegistryTaskChangelogRegistry. defaultChangelogRegistry(int numAsyncDiscardThreads)static TaskChangelogRegistryTaskChangelogRegistry. defaultChangelogRegistry(Executor executor)Methods in org.apache.flink.changelog.fs with parameters of type TaskChangelogRegistry Modifier and Type Method Description static StateChangeUploadSchedulerStateChangeUploadScheduler. fromConfig(org.apache.flink.api.common.JobID jobID, org.apache.flink.configuration.ReadableConfig config, ChangelogStorageMetricGroup metricGroup, TaskChangelogRegistry changelogRegistry, org.apache.flink.runtime.state.LocalRecoveryConfig localRecoveryConfig)Constructors in org.apache.flink.changelog.fs with parameters of type TaskChangelogRegistry Constructor Description AbstractStateChangeFsUploader(boolean compression, int bufferSize, ChangelogStorageMetricGroup metrics, TaskChangelogRegistry changelogRegistry, java.util.function.BiFunction<org.apache.flink.core.fs.Path,Long,org.apache.flink.runtime.state.StreamStateHandle> handleFactory)DuplicatingStateChangeFsUploader(org.apache.flink.api.common.JobID jobID, org.apache.flink.core.fs.Path basePath, org.apache.flink.core.fs.FileSystem fileSystem, boolean compression, int bufferSize, ChangelogStorageMetricGroup metrics, TaskChangelogRegistry changelogRegistry, org.apache.flink.runtime.state.LocalRecoveryDirectoryProvider localRecoveryDirectoryProvider)FsStateChangelogStorage(org.apache.flink.api.common.JobID jobID, org.apache.flink.configuration.Configuration config, org.apache.flink.runtime.metrics.groups.TaskManagerJobMetricGroup metricGroup, TaskChangelogRegistry changelogRegistry, org.apache.flink.runtime.state.LocalRecoveryConfig localRecoveryConfig)FsStateChangelogStorage(org.apache.flink.api.common.JobID jobID, org.apache.flink.core.fs.Path basePath, boolean compression, int bufferSize, ChangelogStorageMetricGroup metricGroup, TaskChangelogRegistry changelogRegistry, org.apache.flink.runtime.state.LocalRecoveryConfig localRecoveryConfig)FsStateChangelogStorage(StateChangeUploadScheduler uploader, long preEmptivePersistThresholdInBytes, TaskChangelogRegistry changelogRegistry, org.apache.flink.runtime.state.LocalRecoveryConfig localRecoveryConfig)StateChangeFsUploader(org.apache.flink.api.common.JobID jobID, org.apache.flink.core.fs.Path basePath, org.apache.flink.core.fs.FileSystem fileSystem, boolean compression, int bufferSize, ChangelogStorageMetricGroup metrics, TaskChangelogRegistry changelogRegistry)StateChangeFsUploader(org.apache.flink.api.common.JobID jobID, org.apache.flink.core.fs.Path basePath, org.apache.flink.core.fs.FileSystem fileSystem, boolean compression, int bufferSize, ChangelogStorageMetricGroup metrics, TaskChangelogRegistry changelogRegistry, java.util.function.BiFunction<org.apache.flink.core.fs.Path,Long,org.apache.flink.runtime.state.StreamStateHandle> handleFactory)
-