| 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.
|
| ForStDBPutRequest<K,V> |
The Put access request for ForStDB.
|
| ForStGeneralMultiGetOperation |
The general-purpose multiGet operation implementation for ForStDB, which simulates multiGet by
calling the Get API multiple times with multiple threads.
|
| ForStKeyedStateBackend<K> |
A KeyedStateBackend that stores its state in ForSt.
|
| ForStKeyedStateBackendBuilder<K> |
|
| 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.
|
| ForStOptions |
Configuration options for the ForStStateBackend.
|
| ForStResourceContainer |
The container for ForSt resources, including option factory and shared resource among instances.
|
| ForStStateBackend |
A StateBackend that stores its state in a ForSt instance.
|
| ForStStateBackendFactory |
|
| 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.
|