Uses of Class
org.apache.flink.state.forst.fs.cache.FileBasedCache
-
Packages that use FileBasedCache Package Description org.apache.flink.state.forst.fs org.apache.flink.state.forst.fs.cache org.apache.flink.state.forst.fs.filemapping -
-
Uses of FileBasedCache in org.apache.flink.state.forst.fs
Methods in org.apache.flink.state.forst.fs that return FileBasedCache Modifier and Type Method Description static FileBasedCacheForStFlinkFileSystem. getFileBasedCache(org.apache.flink.configuration.ReadableConfig config, org.apache.flink.core.fs.Path cacheBase, org.apache.flink.core.fs.Path remoteForStPath, long cacheCapacity, long cacheReservedSize, org.apache.flink.metrics.MetricGroup metricGroup)Methods in org.apache.flink.state.forst.fs with parameters of type FileBasedCache Modifier and Type Method Description static ForStFlinkFileSystemForStFlinkFileSystem. get(URI uri, org.apache.flink.core.fs.Path localBase, FileBasedCache fileBasedCache)Constructors in org.apache.flink.state.forst.fs with parameters of type FileBasedCache Constructor Description ForStFlinkFileSystem(org.apache.flink.core.fs.FileSystem delegateFS, String remoteBase, String localBase, FileBasedCache fileBasedCache) -
Uses of FileBasedCache in org.apache.flink.state.forst.fs.cache
Constructors in org.apache.flink.state.forst.fs.cache with parameters of type FileBasedCache Constructor Description CachedDataInputStream(FileBasedCache fileBasedCache, FileCacheEntry cacheEntry, org.apache.flink.core.fs.FSDataInputStream originalStream)CachedDataInputStream(FileBasedCache fileBasedCache, FileCacheEntry cacheEntry, org.apache.flink.core.fs.FSDataInputStream cacheStream, org.apache.flink.core.fs.FSDataInputStream originalStream)CachedDataOutputStream(org.apache.flink.core.fs.Path originalPath, org.apache.flink.core.fs.Path cachePath, org.apache.flink.core.fs.FSDataOutputStream originalOutputStream, org.apache.flink.core.fs.FSDataOutputStream cacheOutputStream, FileBasedCache cache) -
Uses of FileBasedCache in org.apache.flink.state.forst.fs.filemapping
Methods in org.apache.flink.state.forst.fs.filemapping with parameters of type FileBasedCache Modifier and Type Method Description MappingEntryFileMappingManager. createNewFile(org.apache.flink.core.fs.Path filePath, boolean overwrite, FileBasedCache cache)Create a new file in the mapping table.MappingEntryFileMappingManager. registerReusedRestoredFile(String key, org.apache.flink.runtime.state.StreamStateHandle stateHandle, org.apache.flink.core.fs.Path dbFilePath, FileBasedCache cache)Register a file restored from checkpoints to the mapping table.Constructors in org.apache.flink.state.forst.fs.filemapping with parameters of type FileBasedCache Constructor Description MappingEntry(int initReference, MappingEntrySource source, FileOwnership fileOwnership, FileBasedCache cache, boolean isDirectory, boolean writing)
-