Package | Description |
---|---|
org.apache.flink.changelog.fs |
Modifier and Type | Method and Description |
---|---|
static StateChangeUploadScheduler |
StateChangeUploadScheduler.directScheduler(StateChangeUploader uploader) |
static StateChangeUploadScheduler |
StateChangeUploadScheduler.fromConfig(JobID jobID,
ReadableConfig config,
ChangelogStorageMetricGroup metricGroup,
TaskChangelogRegistry changelogRegistry,
LocalRecoveryConfig localRecoveryConfig) |
Constructor and Description |
---|
FsStateChangelogStorage(StateChangeUploadScheduler uploader,
long preEmptivePersistThresholdInBytes,
TaskChangelogRegistry changelogRegistry,
LocalRecoveryConfig localRecoveryConfig) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.