All Classes

Class	Description
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.
ConfigurableForStOptionsFactory	An interface for options factory that pick up additional parameters from a configuration.
ContextKey<K>	The composite key which contains some context information, such as keyGroup, etc.
ForStConfigurableOptions	This class contains the configuration options for the ForStStateBackend.
ForStDBGetRequest<K,V>	The Get access request for ForStDB.
ForStDBOperation	Data access operation to ForStDB.
ForStDBPutRequest<K,V>	The Put access request for ForStDB.
ForStFlinkFileSystem	A FileSystem delegates some requests to file system loaded by Flink FileSystem mechanism.
ForStGeneralMultiGetOperation	The general-purpose multiGet operation implementation for ForStDB, which simulates multiGet by calling the Get API multiple times with multiple threads.
ForStInnerTable<K,V>	The concept of an abstracted table oriented towards ForStDB, and each ForStInnerTable can be mapped to a ForSt internal State.
ForStKeyedStateBackend<K>	A KeyedStateBackend that stores its state in ForSt.
ForStKeyedStateBackendBuilder<K>	Builder class for ForStKeyedStateBackend which handles all necessary initializations and cleanups.
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.
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.
ForStOptions	Configuration options for the ForStStateBackend.
ForStOptionsFactory	A factory for DBOptions and ColumnFamilyOptions to be passed to the ForStStateBackend.
ForStProperty	RocksDB properties that can be queried by Flink's metrics reporter.
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.
ForStStateBackend	A StateBackend that stores its state in a ForSt instance.
ForStStateBackendFactory	A factory that creates an ForStStateBackend from a configuration.
ForStStateExecutor	The StateExecutor implementation which executing batch StateRequests for ForStStateBackend.
ForStStateRequestClassifier	The ForSt StateRequestContainer which can classify the state requests by ForStDB requestType (Get、Put or Iterator).
ForStValueState<K,V>	The InternalValueState implement for ForStDB.
ForStWriteBatchOperation	The writeBatch operation implementation for ForStDB.