All Classes

Class	Description
AbstractForStStateKeysIterator<K>	Base class for iterators over RocksDB column families.
AbstractForStSyncState<K,N,V>	Base class for State implementations that store state in a RocksDB database.
BundledCacheLimitPolicy	A bundled cache limit policy, any two cache policies can be combined.
ByteBufferReadableFSDataInputStream	A FSDataInputStream delegates requests to other one and supports reading data with ByteBuffer.
ByteBufferWritableFSDataOutputStream	A FSDataOutputStream delegates requests to other one and supports writing data with ByteBuffer.
CachedDataInputStream	A FSDataInputStream delegates requests to other one and supports reading data with ByteBuffer.
CachedDataOutputStream	A FSDataOutputStream delegates requests to other one and supports writing data with ByteBuffer.
CacheLimitPolicy	Cache limit policy.
ConfigurableForStOptionsFactory	An interface for options factory that pick up additional parameters from a configuration.
ContextKey<K,N>	The composite key which contains some context information, such as keyGroup, etc.
CopyDataTransferStrategy	Data transfer strategy for ForSt DB without a remote DB path.
DataTransferStrategy	Base class for data transfer strategy, called by ForSt to transfer data between Checkpoint and DB.
DataTransferStrategyBuilder	Builder for DataTransferStrategy for snapshots.
DoubleListLru<K,V>	A double link LRU (Least Recently Used) cache implementation.
FileBackedMappingEntrySource	A MappingEntrySource backed by a Path.
FileBasedCache	A file-granularity LRU cache.
FileCacheEntry	A file cache entry that encapsulates file and the size of the file, and provides methods to read or write file.
FileCacheEntry.EntryStatus	The status of a file cache entry.
FileMappingManager	A manager to manage file mapping of forst file system, including misc file mapping (remote file -> local file) and linked mapping (remote file -> remote file).
FileOwnership	Indicates the ownership of a file in ForSt DB.
FileOwnershipDecider
ForStAggregatingState<K,N,IN,ACC,OUT>	The implementation of AggregatingState for ForStDB.
ForStConfigurableOptions	This class contains the configuration options for the ForStStateBackend.
ForStDBBunchPutRequest<K,N,UK,UV>	The Bunch Put access request for ForStDB.
ForStDBCachingPriorityQueueSet<E extends org.apache.flink.runtime.state.heap.HeapPriorityQueueElement>	A priority queue with set semantics, implemented on top of RocksDB.
ForStDBCachingPriorityQueueSet.OrderedByteArraySetCache	Cache that is organized as an ordered set for byte-arrays.
ForStDBGetRequest<K,N,V,R>	The Get access request for ForStDB.
ForStDBIterRequest<K,N,UK,UV,R>	The abstract iterator access request for ForStDB.
ForStDBListGetRequest<K,N,V>	The Get access request for ForStDB.
ForStDBMapCheckRequest<K,N,V>	The Map#isEmpty() and Map#contains() request for ForStDB.
ForStDBMapEntryIterRequest<K,N,UK,UV>	The ForSt ForStDBIterRequest which returns the entries of a ForStMapState.
ForStDBMapKeyIterRequest<K,N,UK,UV>	The ForSt ForStDBIterRequest which returns the keys of a ForStMapState.
ForStDBMapValueIterRequest<K,N,UK,UV>	The ForSt ForStDBIterRequest which returns the values of a ForStMapState.
ForStDBMultiRawMergePutRequest<K,N,V>	The Put access request for ForStDB.
ForStDBOperation	Data access operation to ForStDB.
ForStDBPriorityQueueSetFactory	Encapsulates the logic and resources in connection with creating priority queue state structures, for RocksDB backend.
ForStDBPutRequest<K,N,V>	The Put access request for ForStDB.
ForStDBRawGetRequest<K,N,V>	The Get access request for ForStDB.
ForStDBSingleGetRequest<K,N,V>	The Get access request for ForStDB.
ForStDBTtlCompactFiltersManager	RocksDB compaction filter utils for state with TTL.
ForStDBWriteBatchWrapper	It's a wrapper class around ForStDB's WriteBatch for writing in bulk.
ForStFileStatus	A wrapper of FileStatus just for ForSt.
ForStFlinkFileSystem	A FileSystem delegates some requests to file system loaded by Flink FileSystem mechanism.
ForStFlinkFileSystem.FileStatusWrapper
ForStGeneralMultiGetOperation	The general-purpose multiGet operation implementation for ForStDB, which simulates multiGet by calling the Get API multiple times with multiple threads.
ForStHeapTimersFullRestoreOperation<K>	Encapsulates the process of restoring a ForStDB instance from a full snapshot.
ForStIncrementalCheckpointUtils	Utils for RocksDB Incremental Checkpoint.
ForStIncrementalCheckpointUtils.RangeCheckResult	Helper class that represents the result of a range check of the actual keys in a RocksDB instance against the proclaimed key-group range of the instance.
ForStIncrementalRestoreOperation<K>	Encapsulates the process of restoring a ForSt instance from an incremental snapshot.
ForStIncrementalRestoreOperation.RestoredDBInstance	Entity to hold the temporary RocksDB instance created for restore.
ForStIncrementalSnapshotStrategy<K>	Snapshot strategy for ForStKeyedStateBackend that is based on disableFileDeletions()+getLiveFiles() of ForSt and creates incremental snapshots.
ForStInnerTable<K,N,V>	The concept of an abstracted table oriented towards ForStDB, and each ForStInnerTable can be mapped to a ForSt internal State.
ForStIterateOperation	The iterate operation implementation for ForStDB, which leverages rocksdb's iterator directly.
ForStIteratorWrapper	This class was originally a wrapper around RocksIterator to check the iterator status for all the methods mentioned to require this check in the wiki documentation: seek, next, seekToFirst, seekToLast, seekForPrev, and prev.
ForStKeyedStateBackend<K>	A KeyedStateBackend that stores its state in ForSt.
ForStKeyedStateBackendBuilder<K>	Builder class for ForStKeyedStateBackend which handles all necessary initializations and cleanups.
ForStListIterator<V>	The forst implementation for list iterator.
ForStListState<K,N,V>	The AbstractListState implement for ForStDB.
ForStMapIterator<T>	The map iterator implementation for ForStDB.
ForStMapState<K,N,UK,UV>	The AbstractMapState implement for ForStDB.
ForStMemoryConfiguration	The settings regarding ForSt memory usage.
ForStMemoryControllerUtils	Utils to create Cache and WriteBufferManager which are used to control total memory usage of ForSt.
ForStMemoryControllerUtils.ForStMemoryFactory	Factory for Write Buffer Manager and Bock Cache.
ForStNativeFullSnapshotStrategy<K>	Snapshot strategy for ForStKeyedStateBackend that is based on disableFileDeletions()+getLiveFiles() of ForSt and creates full snapshots.
ForStNativeMetricMonitor	A monitor which pulls {RocksDB} native metrics and forwards them to Flink's metric group.
ForStNativeMetricOptions	Enable which ForSt metrics to forward to Flink's metrics reporter.
ForStNoneRestoreOperation	Encapsulates the process of initiating a ForSt instance without restore.
ForStOperationUtils	Utils for ForSt Operations.
ForStOperationUtils.ForStKvStateInfo	ForSt specific information about the k/v states.
ForStOptions	Configuration options for the ForStStateBackend.
ForStOptionsFactory	A factory for DBOptions and ColumnFamilyOptions to be passed to the ForStStateBackend.
ForStPathContainer	Container for ForSt paths.
ForStPriorityQueueConfig	The configuration of ForSt priority queue state implementation.
ForStProperty	RocksDB properties that can be queried by Flink's metrics reporter.
ForStReducingState<K,N,V>	The AbstractReducingState implement for ForStDB.
ForStResourceContainer	The container for ForSt resources, including option factory and shared resource among instances.
ForStRestoreOperation	Interface for ForSt restore.
ForStRestoreResult	Entity holding result of ForSt instance restore.
ForStSerializerUtils	A utility of serialization keys in ForSt.
ForStSnapshotStrategyBase<K,R extends org.apache.flink.runtime.state.SnapshotResources>	Abstract base class for SnapshotStrategy implementations for ForSt state backend.
ForStSnapshotStrategyBase.ForStNativeSnapshotResources	A SnapshotResources for native ForSt snapshot.
ForStSnapshotStrategyBase.PreviousSnapshot	Previous snapshot with uploaded sst files.
ForStSnapshotUtil	Utility methods and constants around ForSt creating and restoring snapshots for ForStStateBackend.
ForStStateBackend	A StateBackend that stores its state in a ForSt instance.
ForStStateBackend.PriorityQueueStateType	The options to chose for the type of priority queue state.
ForStStateBackendFactory	A factory that creates an ForStStateBackend from a configuration.
ForStStateDataTransfer	Data transfer util class for ForStKeyedStateBackend.
ForStStateExecutor	The StateExecutor implementation which executing batch StateRequests for ForStStateBackend.
ForStStateKeysAndNamespaceIterator<K,N>	Adapter class to bridge between ForStIteratorWrapper and Iterator to iterate over the keys and namespaces.
ForStStateKeysIterator<K>	Adapter class to bridge between ForStIteratorWrapper and Iterator to iterate over the keys.
ForStStateRequestClassifier	The ForSt AsyncRequestContainer which can classify the state requests by ForStDB requestType (Get、Put or Iterator).
ForStStateRequestType	ForSt customized state request other than StateRequestType.
ForStSyncKeyedStateBackend<K>	An AbstractKeyedStateBackend that stores its state in ForStDB and serializes state to streams provided by a CheckpointStreamFactory upon checkpointing.
ForStSyncKeyedStateBackendBuilder<K>	Builder class for ForStSyncKeyedStateBackend which handles all necessary initializations and clean ups.
ForStValueState<K,N,V>	The AbstractValueState implement for ForStDB.
ForStWriteBatchOperation	The writeBatch operation implementation for ForStDB.
FSDataOutputStreamWithEntry	A FSDataOutputStream that is associated with a MappingEntry.
HandleBackedMappingEntrySource	A MappingEntrySource backed by a StreamStateHandle.
ListDelimitedSerializer	Encapsulates a logic of serialization and deserialization of a list with a delimiter.
MappingEntry	A file mapping entry that encapsulates source and destination path.
MappingEntrySource	Indicates the source file of the MappingEntry.
ReusableDataTransferStrategy	Data transfer strategy for ForSt DB with a remote DB path.
SizeBasedCacheLimitPolicy	A fixed capacity cache limit policy, which is not thread-safe, and the thread safe should be ensured by the invoker.
SpaceBasedCacheLimitPolicy	A space based cache limit policy that leverages the system to check the free space dynamically, the free space may fluctuate in size due to other components.
StateHandleTransferSpec	This class represents a transfer specification for the content of one IncrementalRemoteKeyedStateHandle to a target Path.
StringifiedForStFileSystem	A ForStFlinkFileSystem stringifies all the parameters of all methods.
TreeOrderedSetCache	Implementation of a lexicographically ordered set of byte-arrays, based on a TreeSet.