@Experimental @ThreadSafe public class FsStateChangelogStorage extends Object implements StateChangelogStorage<ChangelogStateHandleStreamImpl>
StateChangelogStorage
.Constructor and Description |
---|
FsStateChangelogStorage(Configuration config,
TaskManagerJobMetricGroup metricGroup) |
FsStateChangelogStorage(Path basePath,
boolean compression,
int bufferSize,
ChangelogStorageMetricGroup metricGroup) |
FsStateChangelogStorage(org.apache.flink.changelog.fs.StateChangeUploadScheduler uploader,
long preEmptivePersistThresholdInBytes) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
StateChangelogHandleReader<ChangelogStateHandleStreamImpl> |
createReader() |
org.apache.flink.changelog.fs.FsStateChangelogWriter |
createWriter(String operatorID,
KeyGroupRange keyGroupRange,
MailboxExecutor mailboxExecutor) |
AvailabilityProvider |
getAvailabilityProvider() |
public FsStateChangelogStorage(Configuration config, TaskManagerJobMetricGroup metricGroup) throws IOException
IOException
@VisibleForTesting public FsStateChangelogStorage(Path basePath, boolean compression, int bufferSize, ChangelogStorageMetricGroup metricGroup) throws IOException
IOException
@VisibleForTesting public FsStateChangelogStorage(org.apache.flink.changelog.fs.StateChangeUploadScheduler uploader, long preEmptivePersistThresholdInBytes)
public org.apache.flink.changelog.fs.FsStateChangelogWriter createWriter(String operatorID, KeyGroupRange keyGroupRange, MailboxExecutor mailboxExecutor)
createWriter
in interface StateChangelogStorage<ChangelogStateHandleStreamImpl>
public StateChangelogHandleReader<ChangelogStateHandleStreamImpl> createReader()
createReader
in interface StateChangelogStorage<ChangelogStateHandleStreamImpl>
public void close() throws Exception
close
in interface AutoCloseable
close
in interface StateChangelogStorage<ChangelogStateHandleStreamImpl>
Exception
public AvailabilityProvider getAvailabilityProvider()
getAvailabilityProvider
in interface StateChangelogStorage<ChangelogStateHandleStreamImpl>
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.