@Experimental @ThreadSafe public class FsStateChangelogStorage extends Object implements StateChangelogStorage<ChangelogStateHandleStreamImpl>
StateChangelogStorage
.Constructor and Description |
---|
FsStateChangelogStorage(Configuration config) |
FsStateChangelogStorage(Path basePath,
boolean compression,
int bufferSize) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
StateChangelogHandleReader<ChangelogStateHandleStreamImpl> |
createReader() |
org.apache.flink.changelog.fs.FsStateChangelogWriter |
createWriter(String operatorID,
KeyGroupRange keyGroupRange) |
public FsStateChangelogStorage(Configuration config) throws IOException
IOException
@VisibleForTesting public FsStateChangelogStorage(Path basePath, boolean compression, int bufferSize) throws IOException
IOException
public org.apache.flink.changelog.fs.FsStateChangelogWriter createWriter(String operatorID, KeyGroupRange keyGroupRange)
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
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.