Package org.apache.flink.state.forst

Interface Summary

Interface	Description
ConfigurableForStOptionsFactory	An interface for options factory that pick up additional parameters from a configuration.
ForStDBOperation	Data access operation to ForStDB.
ForStInnerTable<K,N,V>	The concept of an abstracted table oriented towards ForStDB, and each ForStInnerTable can be mapped to a ForSt internal State.
ForStMemoryControllerUtils.ForStMemoryFactory	Factory for Write Buffer Manager and Bock Cache.
ForStOptionsFactory	A factory for DBOptions and ColumnFamilyOptions to be passed to the ForStStateBackend.

Class Summary

Class	Description
ContextKey<K,N>	The composite key which contains some context information, such as keyGroup, etc.
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.
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.
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.
ForStGeneralMultiGetOperation	The general-purpose multiGet operation implementation for ForStDB, which simulates multiGet by calling the Get API multiple times with multiple threads.
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.
ForStIterateOperation	The iterate operation implementation for ForStDB, which leverages rocksdb's iterator directly.
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.
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.
ForStOperationUtils	Utils for ForSt Operations.
ForStOperationUtils.ForStKvStateInfo	ForSt specific information about the k/v states.
ForStOptions	Configuration options for the ForStStateBackend.
ForStPathContainer	Container for ForSt paths.
ForStReducingState<K,N,V>	The AbstractReducingState implement for ForStDB.
ForStResourceContainer	The container for ForSt resources, including option factory and shared resource among instances.
ForStSerializerUtils	A utility of serialization keys in ForSt.
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,N,V>	The AbstractValueState implement for ForStDB.
ForStWriteBatchOperation	The writeBatch operation implementation for ForStDB.
ListDelimitedSerializer	Encapsulates a logic of serialization and deserialization of a list with a delimiter.
StateHandleTransferSpec	This class represents a transfer specification for the content of one IncrementalRemoteKeyedStateHandle to a target Path.

Enum Summary

Enum	Description
ForStProperty	RocksDB properties that can be queried by Flink's metrics reporter.
ForStStateBackend.PriorityQueueStateType	The options to chose for the type of priority queue state.
ForStStateRequestType	ForSt customized state request other than StateRequestType.