Index (Flink : State backends : ForSt 1.20.1-cp2 API)

A B C D E F G H I K L M N O P R S T U V W
All Classes All Packages

A

ActualDelayedWriteRate - org.apache.flink.state.forst.ForStProperty
allocateForStSharedResources(long, double, double, boolean, ForStMemoryControllerUtils.ForStMemoryFactory) - Static method in class org.apache.flink.state.forst.ForStMemoryControllerUtils: Allocate memory controllable ForSt shared resources.
allocateSharedCachesIfConfigured(ForStMemoryConfiguration, Environment, double, Logger, ForStMemoryControllerUtils.ForStMemoryFactory) - Static method in class org.apache.flink.state.forst.ForStOperationUtils
available() - Method in class org.apache.flink.state.forst.fs.ByteBufferReadableFSDataInputStream

B

BackgroundErrors - org.apache.flink.state.forst.ForStProperty
BLOCK_CACHE_CAPACITY - Static variable in class org.apache.flink.state.forst.ForStNativeMetricOptions
BLOCK_CACHE_PINNED_USAGE - Static variable in class org.apache.flink.state.forst.ForStNativeMetricOptions
BLOCK_CACHE_SIZE - Static variable in class org.apache.flink.state.forst.ForStConfigurableOptions
BLOCK_CACHE_USAGE - Static variable in class org.apache.flink.state.forst.ForStNativeMetricOptions
BLOCK_SIZE - Static variable in class org.apache.flink.state.forst.ForStConfigurableOptions
BlockCacheCapacity - org.apache.flink.state.forst.ForStProperty
BlockCachePinnedUsage - org.apache.flink.state.forst.ForStProperty
BlockCacheUsage - org.apache.flink.state.forst.ForStProperty
BLOOM_FILTER_BITS_PER_KEY - Static variable in class org.apache.flink.state.forst.ForStConfigurableOptions
BLOOM_FILTER_BLOCK_BASED_MODE - Static variable in class org.apache.flink.state.forst.ForStConfigurableOptions
build() - Method in class org.apache.flink.state.forst.ForStKeyedStateBackendBuilder
buildDBGetRequest(StateRequest<?, ?, ?>) - Method in interface org.apache.flink.state.forst.ForStInnerTable: Build a ForStDBGetRequest that belong to this ForStInnerTable with the given stateRequest.
buildDBGetRequest(StateRequest<?, ?, ?>) - Method in class org.apache.flink.state.forst.ForStValueState
buildDBPutRequest(StateRequest<?, ?, ?>) - Method in interface org.apache.flink.state.forst.ForStInnerTable: Build a ForStDBPutRequest that belong to ForStInnerTable with the given stateRequest.
buildDBPutRequest(StateRequest<?, ?, ?>) - Method in class org.apache.flink.state.forst.ForStValueState
buildSerializedKey() - Method in class org.apache.flink.state.forst.ForStDBGetRequest
buildSerializedKey() - Method in class org.apache.flink.state.forst.ForStDBPutRequest
buildSerializedValue() - Method in class org.apache.flink.state.forst.ForStDBPutRequest
ByteBufferReadableFSDataInputStream - Class in org.apache.flink.state.forst.fs: A FSDataInputStream delegates requests to other one and supports reading data with ByteBuffer.
ByteBufferReadableFSDataInputStream(Callable<FSDataInputStream>, int, long) - Constructor for class org.apache.flink.state.forst.fs.ByteBufferReadableFSDataInputStream
ByteBufferWritableFSDataOutputStream - Class in org.apache.flink.state.forst.fs: A FSDataOutputStream delegates requests to other one and supports writing data with ByteBuffer.
ByteBufferWritableFSDataOutputStream(FSDataOutputStream) - Constructor for class org.apache.flink.state.forst.fs.ByteBufferWritableFSDataOutputStream

C

calculateActualCacheCapacity(long, double) - Static method in class org.apache.flink.state.forst.ForStMemoryControllerUtils: Calculate the actual memory capacity of cache, which would be shared among ForSt instance(s).
clearDirectories() - Method in class org.apache.flink.state.forst.ForStResourceContainer: Clear local and remote directories.
close() - Method in class org.apache.flink.state.forst.ForStKeyedStateBackend
close() - Method in class org.apache.flink.state.forst.ForStNativeMetricMonitor
close() - Method in class org.apache.flink.state.forst.ForStResourceContainer
close() - Method in class org.apache.flink.state.forst.fs.ByteBufferReadableFSDataInputStream
close() - Method in class org.apache.flink.state.forst.fs.ByteBufferWritableFSDataOutputStream
close() - Method in class org.apache.flink.state.forst.restore.ForStNoneRestoreOperation
COLUMN_FAMILY_AS_VARIABLE - Static variable in class org.apache.flink.state.forst.ForStNativeMetricOptions
COMPACTION_STYLE - Static variable in class org.apache.flink.state.forst.ForStConfigurableOptions
CompactionPending - org.apache.flink.state.forst.ForStProperty
completeStateFuture() - Method in class org.apache.flink.state.forst.ForStDBPutRequest
completeStateFuture(byte[]) - Method in class org.apache.flink.state.forst.ForStDBGetRequest
completeStateFutureExceptionally(String, Throwable) - Method in class org.apache.flink.state.forst.ForStDBGetRequest
completeStateFutureExceptionally(String, Throwable) - Method in class org.apache.flink.state.forst.ForStDBPutRequest
COMPRESSION_PER_LEVEL - Static variable in class org.apache.flink.state.forst.ForStConfigurableOptions
ConfigurableForStOptionsFactory - Interface in org.apache.flink.state.forst: An interface for options factory that pick up additional parameters from a configuration.
configure(ReadableConfig) - Method in interface org.apache.flink.state.forst.ConfigurableForStOptionsFactory: Creates a variant of the options factory that applies additional configuration parameters.
configure(ReadableConfig, ClassLoader) - Method in class org.apache.flink.state.forst.ForStStateBackend: Creates a copy of this state backend that uses the values defined in the configuration for fields where that were not yet specified in this state backend.
ContextKey<K> - Class in org.apache.flink.state.forst: The composite key which contains some context information, such as keyGroup, etc.
ContextKey(RecordContext<K>) - Constructor for class org.apache.flink.state.forst.ContextKey
create(Path) - Method in class org.apache.flink.state.forst.fs.ForStFlinkFileSystem: Create ByteBufferWritableFSDataOutputStream from specific path which supports to write data to ByteBuffer with FileSystem.WriteMode.OVERWRITE mode.
create(Path, FileSystem.WriteMode) - Method in class org.apache.flink.state.forst.fs.ForStFlinkFileSystem
createAsyncKeyedStateBackend(StateBackend.KeyedStateBackendParameters<K>) - Method in class org.apache.flink.state.forst.ForStStateBackend
createCache(long, double) - Method in interface org.apache.flink.state.forst.ForStMemoryControllerUtils.ForStMemoryFactory
createColumnFamilyDescriptor(String, Function<String, ColumnFamilyOptions>) - Static method in class org.apache.flink.state.forst.ForStOperationUtils: Creates a column descriptor for a state column family.
createColumnFamilyHandle(String, RocksDB, Function<String, ColumnFamilyOptions>) - Static method in class org.apache.flink.state.forst.ForStOperationUtils: Creates a column family handle from a state id.
createColumnFamilyOptions(Function<String, ColumnFamilyOptions>, String) - Static method in class org.apache.flink.state.forst.ForStOperationUtils
createColumnOptions(ColumnFamilyOptions, Collection<AutoCloseable>) - Method in interface org.apache.flink.state.forst.ForStOptionsFactory: This method should set the additional options on top of the current options object.
createDBOptions(DBOptions, Collection<AutoCloseable>) - Method in interface org.apache.flink.state.forst.ForStOptionsFactory: This method should set the additional options on top of the current options object.
createFromConfig(ReadableConfig, ClassLoader) - Method in class org.apache.flink.state.forst.ForStStateBackendFactory
createKeyedStateBackend(StateBackend.KeyedStateBackendParameters<K>) - Method in class org.apache.flink.state.forst.ForStStateBackend
createNativeMetricsOptions(ForStNativeMetricOptions) - Method in interface org.apache.flink.state.forst.ForStOptionsFactory: This method should enable certain ForSt metrics to be forwarded to Flink's metrics reporter.
createOperatorStateBackend(StateBackend.OperatorStateBackendParameters) - Method in class org.apache.flink.state.forst.ForStStateBackend
createReadOptions(ReadOptions, Collection<AutoCloseable>) - Method in interface org.apache.flink.state.forst.ForStOptionsFactory: This method should set the additional options on top of the current options object.
createState(StateDescriptor<SV>) - Method in class org.apache.flink.state.forst.ForStKeyedStateBackend
createStateExecutor() - Method in class org.apache.flink.state.forst.ForStKeyedStateBackend
createStateRequestContainer() - Method in class org.apache.flink.state.forst.ForStStateExecutor
createWriteBufferManager(long, Cache) - Method in interface org.apache.flink.state.forst.ForStMemoryControllerUtils.ForStMemoryFactory
createWriteOptions(WriteOptions, Collection<AutoCloseable>) - Method in interface org.apache.flink.state.forst.ForStOptionsFactory: This method should set the additional options on top of the current options object.
CurSizeActiveMemTable - org.apache.flink.state.forst.ForStProperty
CurSizeAllMemTables - org.apache.flink.state.forst.ForStProperty

D

db - Variable in class org.apache.flink.state.forst.ForStKeyedStateBackend: Our ForSt database.
DEFAULT - Static variable in interface org.apache.flink.state.forst.ForStMemoryControllerUtils.ForStMemoryFactory
delete(Path, boolean) - Method in class org.apache.flink.state.forst.fs.ForStFlinkFileSystem
deserializeValue(byte[]) - Method in interface org.apache.flink.state.forst.ForStInnerTable: Deserialize the given bytes value to POJO value.
deserializeValue(byte[]) - Method in class org.apache.flink.state.forst.ForStValueState
dispose() - Method in class org.apache.flink.state.forst.ForStKeyedStateBackend: Should only be called by one thread, and only after all accesses to the DB happened.

E

enableActualDelayedWriteRate() - Method in class org.apache.flink.state.forst.ForStNativeMetricOptions: Returns the current actual delayed write rate.
enableBackgroundErrors() - Method in class org.apache.flink.state.forst.ForStNativeMetricOptions: Returns accumulated number of background errors.
enableBlockCacheCapacity() - Method in class org.apache.flink.state.forst.ForStNativeMetricOptions: Returns block cache capacity.
enableBlockCachePinnedUsage() - Method in class org.apache.flink.state.forst.ForStNativeMetricOptions: Returns the memory size for the entries being pinned in block cache.
enableBlockCacheUsage() - Method in class org.apache.flink.state.forst.ForStNativeMetricOptions: Returns the memory size for the entries residing in block cache.
enableCompactionPending() - Method in class org.apache.flink.state.forst.ForStNativeMetricOptions: Returns 1 if at least one compaction is pending; otherwise, returns 0.
enableCurSizeActiveMemTable() - Method in class org.apache.flink.state.forst.ForStNativeMetricOptions: Returns approximate size of active memtable (bytes).
enableCurSizeAllMemTables() - Method in class org.apache.flink.state.forst.ForStNativeMetricOptions: Returns approximate size of active and unflushed immutable memtables (bytes).
enableEstimateLiveDataSize() - Method in class org.apache.flink.state.forst.ForStNativeMetricOptions: Returns an estimate of the amount of live data in bytes.
enableEstimateNumKeys() - Method in class org.apache.flink.state.forst.ForStNativeMetricOptions: Returns estimated number of total keys in the active and unflushed immutable memtables and storage.
enableEstimatePendingCompactionBytes() - Method in class org.apache.flink.state.forst.ForStNativeMetricOptions: Returns estimated total number of bytes compaction needs to rewrite to get all levels down to under target size.
enableEstimateTableReadersMem() - Method in class org.apache.flink.state.forst.ForStNativeMetricOptions: Returns estimated memory used for reading SST tables, excluding memory used in block cache (e.g.,filter and index blocks).
enableIsWriteStopped() - Method in class org.apache.flink.state.forst.ForStNativeMetricOptions: Returns 1 if write has been stopped.
enableLiveSstFilesSize() - Method in class org.apache.flink.state.forst.ForStNativeMetricOptions
enableMemTableFlushPending() - Method in class org.apache.flink.state.forst.ForStNativeMetricOptions: Returns 1 if a memtable flush is pending; otherwise, returns 0.
enableNativeStatistics(ConfigOption<Boolean>) - Method in class org.apache.flink.state.forst.ForStNativeMetricOptions
enableNumDeletesActiveMemTable() - Method in class org.apache.flink.state.forst.ForStNativeMetricOptions: Returns total number of delete entries in the active memtable.
enableNumDeletesImmMemTables() - Method in class org.apache.flink.state.forst.ForStNativeMetricOptions: Returns total number of delete entries in the unflushed immutable memtables.
enableNumEntriesActiveMemTable() - Method in class org.apache.flink.state.forst.ForStNativeMetricOptions: Returns total number of entries in the active memtable.
enableNumEntriesImmMemTables() - Method in class org.apache.flink.state.forst.ForStNativeMetricOptions: Returns total number of entries in the unflushed immutable memtables.
enableNumFilesAtLevel() - Method in class org.apache.flink.state.forst.ForStNativeMetricOptions: Returns the number of files per level.
enableNumImmutableMemTable() - Method in class org.apache.flink.state.forst.ForStNativeMetricOptions: Returns number of immutable memtables that have not yet been flushed.
enableNumLiveVersions() - Method in class org.apache.flink.state.forst.ForStNativeMetricOptions: Returns number of live versions.
enableNumRunningCompactions() - Method in class org.apache.flink.state.forst.ForStNativeMetricOptions: Returns the number of currently running compactions.
enableNumRunningFlushes() - Method in class org.apache.flink.state.forst.ForStNativeMetricOptions: Returns the number of currently running flushes.
enableNumSnapshots() - Method in class org.apache.flink.state.forst.ForStNativeMetricOptions: Returns number of unreleased snapshots of the database.
enableSizeAllMemTables() - Method in class org.apache.flink.state.forst.ForStNativeMetricOptions: Returns approximate size of active, unflushed immutable, and pinned immutable memtables (bytes).
enableTotalSstFilesSize() - Method in class org.apache.flink.state.forst.ForStNativeMetricOptions: Returns total size (bytes) of all SST files.
equals(Object) - Method in class org.apache.flink.state.forst.ContextKey
ESTIMATE_LIVE_DATA_SIZE - Static variable in class org.apache.flink.state.forst.ForStNativeMetricOptions
ESTIMATE_NUM_KEYS - Static variable in class org.apache.flink.state.forst.ForStNativeMetricOptions
ESTIMATE_PENDING_COMPACTION_BYTES - Static variable in class org.apache.flink.state.forst.ForStNativeMetricOptions
ESTIMATE_TABLE_READERS_MEM - Static variable in class org.apache.flink.state.forst.ForStNativeMetricOptions
EstimateLiveDataSize - org.apache.flink.state.forst.ForStProperty
EstimateNumKeys - org.apache.flink.state.forst.ForStProperty
EstimatePendingCompactionBytes - org.apache.flink.state.forst.ForStProperty
EstimateTableReadersMem - org.apache.flink.state.forst.ForStProperty
executeBatchRequests(StateRequestContainer) - Method in class org.apache.flink.state.forst.ForStStateExecutor

F

FIX_PER_SLOT_MEMORY_SIZE - Static variable in class org.apache.flink.state.forst.ForStOptions
FIX_PER_TM_MEMORY_SIZE - Static variable in class org.apache.flink.state.forst.ForStOptions
flush() - Method in class org.apache.flink.state.forst.fs.ByteBufferWritableFSDataOutputStream
ForStConfigurableOptions - Class in org.apache.flink.state.forst: This class contains the configuration options for the ForStStateBackend.
ForStConfigurableOptions() - Constructor for class org.apache.flink.state.forst.ForStConfigurableOptions
ForStDBGetRequest<K,V> - Class in org.apache.flink.state.forst: The Get access request for ForStDB.
ForStDBOperation - Interface in org.apache.flink.state.forst: Data access operation to ForStDB.
ForStDBPutRequest<K,V> - Class in org.apache.flink.state.forst: The Put access request for ForStDB.
ForStFlinkFileSystem - Class in org.apache.flink.state.forst.fs: A FileSystem delegates some requests to file system loaded by Flink FileSystem mechanism.
ForStFlinkFileSystem(FileSystem) - Constructor for class org.apache.flink.state.forst.fs.ForStFlinkFileSystem
ForStGeneralMultiGetOperation - Class in org.apache.flink.state.forst: The general-purpose multiGet operation implementation for ForStDB, which simulates multiGet by calling the Get API multiple times with multiple threads.
ForStInnerTable<K,V> - Interface in org.apache.flink.state.forst: The concept of an abstracted table oriented towards ForStDB, and each ForStInnerTable can be mapped to a ForSt internal State.
ForStKeyedStateBackend<K> - Class in org.apache.flink.state.forst: A KeyedStateBackend that stores its state in ForSt.
ForStKeyedStateBackend(ForStResourceContainer, TypeSerializer<K>, Supplier<SerializedCompositeKeyBuilder<K>>, Supplier<DataOutputSerializer>, Supplier<DataInputDeserializer>, RocksDB, Function<String, ColumnFamilyOptions>, ColumnFamilyHandle, ForStNativeMetricMonitor) - Constructor for class org.apache.flink.state.forst.ForStKeyedStateBackend
ForStKeyedStateBackendBuilder<K> - Class in org.apache.flink.state.forst: Builder class for ForStKeyedStateBackend which handles all necessary initializations and cleanups.
ForStKeyedStateBackendBuilder(ForStResourceContainer, Function<String, ColumnFamilyOptions>, TypeSerializer<K>, int, MetricGroup, Collection<KeyedStateHandle>) - Constructor for class org.apache.flink.state.forst.ForStKeyedStateBackendBuilder
ForStMemoryConfiguration - Class in org.apache.flink.state.forst: The settings regarding ForSt memory usage.
ForStMemoryConfiguration() - Constructor for class org.apache.flink.state.forst.ForStMemoryConfiguration
ForStMemoryControllerUtils - Class in org.apache.flink.state.forst: Utils to create Cache and WriteBufferManager which are used to control total memory usage of ForSt.
ForStMemoryControllerUtils() - Constructor for class org.apache.flink.state.forst.ForStMemoryControllerUtils
ForStMemoryControllerUtils.ForStMemoryFactory - Interface in org.apache.flink.state.forst: Factory for Write Buffer Manager and Bock Cache.
ForStNativeMetricMonitor - Class in org.apache.flink.state.forst: A monitor which pulls {RocksDB} native metrics and forwards them to Flink's metric group.
ForStNativeMetricMonitor(ForStNativeMetricOptions, MetricGroup, RocksDB, Statistics) - Constructor for class org.apache.flink.state.forst.ForStNativeMetricMonitor
ForStNativeMetricOptions - Class in org.apache.flink.state.forst: Enable which ForSt metrics to forward to Flink's metrics reporter.
ForStNativeMetricOptions() - Constructor for class org.apache.flink.state.forst.ForStNativeMetricOptions
ForStNoneRestoreOperation - Class in org.apache.flink.state.forst.restore: Encapsulates the process of initiating a ForSt instance without restore.
ForStNoneRestoreOperation(File, DBOptions, Function<String, ColumnFamilyOptions>, ForStNativeMetricOptions, MetricGroup) - Constructor for class org.apache.flink.state.forst.restore.ForStNoneRestoreOperation
ForStOperationUtils - Class in org.apache.flink.state.forst: Utils for ForSt Operations.
ForStOperationUtils() - Constructor for class org.apache.flink.state.forst.ForStOperationUtils
ForStOptions - Class in org.apache.flink.state.forst: Configuration options for the ForStStateBackend.
ForStOptions() - Constructor for class org.apache.flink.state.forst.ForStOptions
ForStOptionsFactory - Interface in org.apache.flink.state.forst: A factory for DBOptions and ColumnFamilyOptions to be passed to the ForStStateBackend.
ForStProperty - Enum in org.apache.flink.state.forst: RocksDB properties that can be queried by Flink's metrics reporter.
ForStResourceContainer - Class in org.apache.flink.state.forst: The container for ForSt resources, including option factory and shared resource among instances.
ForStResourceContainer() - Constructor for class org.apache.flink.state.forst.ForStResourceContainer
ForStResourceContainer(ReadableConfig, ForStOptionsFactory, OpaqueMemoryResource<ForStSharedResources>, File, Path, boolean) - Constructor for class org.apache.flink.state.forst.ForStResourceContainer
ForStResourceContainer(ForStOptionsFactory) - Constructor for class org.apache.flink.state.forst.ForStResourceContainer
ForStResourceContainer(ForStOptionsFactory, OpaqueMemoryResource<ForStSharedResources>) - Constructor for class org.apache.flink.state.forst.ForStResourceContainer
ForStRestoreOperation - Interface in org.apache.flink.state.forst.restore: Interface for ForSt restore.
ForStRestoreResult - Class in org.apache.flink.state.forst.restore: Entity holding result of ForSt instance restore.
ForStRestoreResult(RocksDB, ColumnFamilyHandle, ForStNativeMetricMonitor) - Constructor for class org.apache.flink.state.forst.restore.ForStRestoreResult
ForStStateBackend - Class in org.apache.flink.state.forst: A StateBackend that stores its state in a ForSt instance.
ForStStateBackend() - Constructor for class org.apache.flink.state.forst.ForStStateBackend: Creates a new ForStStateBackend for storing state.
ForStStateBackendFactory - Class in org.apache.flink.state.forst: A factory that creates an ForStStateBackend from a configuration.
ForStStateBackendFactory() - Constructor for class org.apache.flink.state.forst.ForStStateBackendFactory
ForStStateExecutor - Class in org.apache.flink.state.forst: The StateExecutor implementation which executing batch StateRequests for ForStStateBackend.
ForStStateExecutor(int, RocksDB, WriteOptions) - Constructor for class org.apache.flink.state.forst.ForStStateExecutor
ForStStateRequestClassifier - Class in org.apache.flink.state.forst: The ForSt StateRequestContainer which can classify the state requests by ForStDB requestType (Get、Put or Iterator).
ForStStateRequestClassifier() - Constructor for class org.apache.flink.state.forst.ForStStateRequestClassifier
ForStValueState<K,V> - Class in org.apache.flink.state.forst: The InternalValueState implement for ForStDB.
ForStValueState(StateRequestHandler, ColumnFamilyHandle, ValueStateDescriptor<V>, Supplier<SerializedCompositeKeyBuilder<K>>, Supplier<DataOutputSerializer>, Supplier<DataInputDeserializer>) - Constructor for class org.apache.flink.state.forst.ForStValueState
ForStWriteBatchOperation - Class in org.apache.flink.state.forst: The writeBatch operation implementation for ForStDB.
fromConfig(ReadableConfig) - Static method in class org.apache.flink.state.forst.ForStNativeMetricOptions: Creates a ForStNativeMetricOptions based on an external configuration.
fromConfiguration(Configuration) - Static method in class org.apache.flink.state.forst.ForStMemoryConfiguration
fromOtherAndConfiguration(ForStMemoryConfiguration, ReadableConfig) - Static method in class org.apache.flink.state.forst.ForStMemoryConfiguration: Derives a ForStMemoryConfiguration from another object and a configuration.

G

get(URI) - Static method in class org.apache.flink.state.forst.fs.ForStFlinkFileSystem: Returns a reference to the FileSystem instance for accessing the file system identified by the given URI.
getColumnFamilyHandle() - Method in class org.apache.flink.state.forst.ForStDBGetRequest
getColumnFamilyHandle() - Method in class org.apache.flink.state.forst.ForStDBPutRequest
getColumnFamilyHandle() - Method in interface org.apache.flink.state.forst.ForStInnerTable: Get the columnFamily handle corresponding to table.
getColumnFamilyHandle() - Method in class org.apache.flink.state.forst.ForStValueState
getColumnOptions() - Method in class org.apache.flink.state.forst.ForStResourceContainer: Gets the ForSt ColumnFamilyOptions to be used for all ForSt instances.
getConfigKey() - Method in enum org.apache.flink.state.forst.ForStProperty
getDb() - Method in class org.apache.flink.state.forst.restore.ForStRestoreResult
getDbOptions() - Method in class org.apache.flink.state.forst.ForStResourceContainer: Gets the ForSt DBOptions to be used for ForSt instances.
getDefaultColumnFamilyHandle() - Method in class org.apache.flink.state.forst.restore.ForStRestoreResult
getFileBlockLocations(FileStatus, long, long) - Method in class org.apache.flink.state.forst.fs.ForStFlinkFileSystem
getFileStatus(Path) - Method in class org.apache.flink.state.forst.fs.ForStFlinkFileSystem
getFixedMemoryPerSlot() - Method in class org.apache.flink.state.forst.ForStMemoryConfiguration: Gets the fixed amount of memory to be shared between all RocksDB instances (in all tasks and operators) of a slot.
getForStOptions() - Method in class org.apache.flink.state.forst.ForStStateBackend: Gets Options for the ForSt instances.
getForStProperty() - Method in enum org.apache.flink.state.forst.ForStProperty
getHighPriorityPoolRatio() - Method in class org.apache.flink.state.forst.ForStMemoryConfiguration: Gets the fraction of the total memory to be used for high priority blocks like indexes, dictionaries, etc.
getHomeDirectory() - Method in class org.apache.flink.state.forst.fs.ForStFlinkFileSystem
getKeyGroup() - Method in class org.apache.flink.state.forst.ContextKey
getKind() - Method in class org.apache.flink.state.forst.fs.ForStFlinkFileSystem
getLocalBasePath() - Method in class org.apache.flink.state.forst.ForStResourceContainer
getLocalDbStoragePaths() - Method in class org.apache.flink.state.forst.ForStStateBackend: Gets the configured local DB storage paths, or null, if none were configured.
getLocalForStPath() - Method in class org.apache.flink.state.forst.ForStResourceContainer
getMonitorTickerTypes() - Method in class org.apache.flink.state.forst.ForStNativeMetricOptions
getNativeMetricMonitor() - Method in class org.apache.flink.state.forst.restore.ForStRestoreResult
getNumericalPropertyValue(RocksDB, ColumnFamilyHandle) - Method in enum org.apache.flink.state.forst.ForStProperty
getOrCreateSerializedKey(FunctionWithException<ContextKey<K>, byte[], IOException>) - Method in class org.apache.flink.state.forst.ContextKey: Get the serialized key.
getPos() - Method in class org.apache.flink.state.forst.fs.ByteBufferReadableFSDataInputStream
getPos() - Method in class org.apache.flink.state.forst.fs.ByteBufferWritableFSDataOutputStream
getProperties() - Method in class org.apache.flink.state.forst.ForStNativeMetricOptions
getRawKey() - Method in class org.apache.flink.state.forst.ContextKey
getReadOptions() - Method in class org.apache.flink.state.forst.ForStResourceContainer: Gets the ForSt ReadOptions to be used for read operations.
getRemoteBasePath() - Method in class org.apache.flink.state.forst.ForStResourceContainer
getRemoteForStPath() - Method in class org.apache.flink.state.forst.ForStResourceContainer
getUri() - Method in class org.apache.flink.state.forst.fs.ForStFlinkFileSystem
getWorkingDirectory() - Method in class org.apache.flink.state.forst.fs.ForStFlinkFileSystem
getWriteBufferRatio() - Method in class org.apache.flink.state.forst.ForStMemoryConfiguration: Gets the fraction of the total memory to be used for write buffers.
getWriteOptions() - Method in class org.apache.flink.state.forst.ForStResourceContainer: Gets the ForSt WriteOptions to be used for write operations.

H

hashCode() - Method in class org.apache.flink.state.forst.ContextKey
HIGH_PRIORITY_POOL_RATIO - Static variable in class org.apache.flink.state.forst.ForStOptions

I

IS_WRITE_STOPPED - Static variable in class org.apache.flink.state.forst.ForStNativeMetricOptions
isColumnFamilyAsVariable() - Method in class org.apache.flink.state.forst.ForStNativeMetricOptions: {ForStNativeMetricMonitor} Whether to expose the column family as a variable..
isDistributedFS() - Method in class org.apache.flink.state.forst.fs.ForStFlinkFileSystem
isEmpty() - Method in class org.apache.flink.state.forst.ForStStateRequestClassifier
isEnabled() - Method in class org.apache.flink.state.forst.ForStNativeMetricOptions: {ForStNativeMetricMonitor} is enabled if any property or ticker type is set.
isStatisticsEnabled() - Method in class org.apache.flink.state.forst.ForStNativeMetricOptions
isUsingFixedMemoryPerSlot() - Method in class org.apache.flink.state.forst.ForStMemoryConfiguration: Gets whether the state backend is configured to use a fixed amount of memory shared between all ForSt instances (in all tasks and operators) of a slot.
isUsingManagedMemory() - Method in class org.apache.flink.state.forst.ForStMemoryConfiguration: Gets whether the state backend is configured to use the managed memory of a slot for ForSt.
isUsingPartitionedIndexFilters() - Method in class org.apache.flink.state.forst.ForStMemoryConfiguration: Gets whether the state backend is configured to use partitioned index/filters for ForSt.
IsWriteStopped - org.apache.flink.state.forst.ForStProperty

K

keySerializer - Variable in class org.apache.flink.state.forst.ForStKeyedStateBackend: The key serializer.

L

listStatus(Path) - Method in class org.apache.flink.state.forst.fs.ForStFlinkFileSystem
LiveSstFilesSize - org.apache.flink.state.forst.ForStProperty
LOCAL_DIRECTORIES - Static variable in class org.apache.flink.state.forst.ForStOptions: The local directory (on the TaskManager) where ForSt puts some meta files.
LOG_DIR - Static variable in class org.apache.flink.state.forst.ForStConfigurableOptions
LOG_FILE_NUM - Static variable in class org.apache.flink.state.forst.ForStConfigurableOptions
LOG_LEVEL - Static variable in class org.apache.flink.state.forst.ForStConfigurableOptions
LOG_MAX_FILE_SIZE - Static variable in class org.apache.flink.state.forst.ForStConfigurableOptions
logger - Variable in class org.apache.flink.state.forst.ForStKeyedStateBackendBuilder

M

mark(int) - Method in class org.apache.flink.state.forst.fs.ByteBufferReadableFSDataInputStream
markSupported() - Method in class org.apache.flink.state.forst.fs.ByteBufferReadableFSDataInputStream
MAX_BACKGROUND_THREADS - Static variable in class org.apache.flink.state.forst.ForStConfigurableOptions
MAX_OPEN_FILES - Static variable in class org.apache.flink.state.forst.ForStConfigurableOptions
MAX_SIZE_LEVEL_BASE - Static variable in class org.apache.flink.state.forst.ForStConfigurableOptions
MAX_WRITE_BUFFER_NUMBER - Static variable in class org.apache.flink.state.forst.ForStConfigurableOptions
MemTableFlushPending - org.apache.flink.state.forst.ForStProperty
MERGE_OPERATOR_NAME - Static variable in class org.apache.flink.state.forst.ForStOperationUtils: The name of the merge operator in ForSt.
METADATA_BLOCK_SIZE - Static variable in class org.apache.flink.state.forst.ForStConfigurableOptions
METRICS_COLUMN_FAMILY_AS_VARIABLE_KEY - Static variable in class org.apache.flink.state.forst.ForStNativeMetricOptions
MIN_WRITE_BUFFER_NUMBER_TO_MERGE - Static variable in class org.apache.flink.state.forst.ForStConfigurableOptions
mkdirs(Path) - Method in class org.apache.flink.state.forst.fs.ForStFlinkFileSystem
MONITOR_ACTUAL_DELAYED_WRITE_RATE - Static variable in class org.apache.flink.state.forst.ForStNativeMetricOptions
MONITOR_BACKGROUND_ERRORS - Static variable in class org.apache.flink.state.forst.ForStNativeMetricOptions
MONITOR_BLOCK_CACHE_HIT - Static variable in class org.apache.flink.state.forst.ForStNativeMetricOptions
MONITOR_BLOCK_CACHE_MISS - Static variable in class org.apache.flink.state.forst.ForStNativeMetricOptions
MONITOR_BLOOM_FILTER_FULL_POSITIVE - Static variable in class org.apache.flink.state.forst.ForStNativeMetricOptions
MONITOR_BLOOM_FILTER_FULL_TRUE_POSITIVE - Static variable in class org.apache.flink.state.forst.ForStNativeMetricOptions
MONITOR_BLOOM_FILTER_USEFUL - Static variable in class org.apache.flink.state.forst.ForStNativeMetricOptions
MONITOR_BYTES_READ - Static variable in class org.apache.flink.state.forst.ForStNativeMetricOptions
MONITOR_BYTES_WRITTEN - Static variable in class org.apache.flink.state.forst.ForStNativeMetricOptions
MONITOR_COMPACTION_READ_BYTES - Static variable in class org.apache.flink.state.forst.ForStNativeMetricOptions
MONITOR_COMPACTION_WRITE_BYTES - Static variable in class org.apache.flink.state.forst.ForStNativeMetricOptions
MONITOR_CUR_SIZE_ACTIVE_MEM_TABLE - Static variable in class org.apache.flink.state.forst.ForStNativeMetricOptions
MONITOR_CUR_SIZE_ALL_MEM_TABLE - Static variable in class org.apache.flink.state.forst.ForStNativeMetricOptions
MONITOR_ITER_BYTES_READ - Static variable in class org.apache.flink.state.forst.ForStNativeMetricOptions
MONITOR_LIVE_SST_FILES_SIZE - Static variable in class org.apache.flink.state.forst.ForStNativeMetricOptions
MONITOR_MEM_TABLE_FLUSH_PENDING - Static variable in class org.apache.flink.state.forst.ForStNativeMetricOptions
MONITOR_NUM_DELETES_ACTIVE_MEM_TABLE - Static variable in class org.apache.flink.state.forst.ForStNativeMetricOptions
MONITOR_NUM_DELETES_IMM_MEM_TABLE - Static variable in class org.apache.flink.state.forst.ForStNativeMetricOptions
MONITOR_NUM_ENTRIES_ACTIVE_MEM_TABLE - Static variable in class org.apache.flink.state.forst.ForStNativeMetricOptions
MONITOR_NUM_ENTRIES_IMM_MEM_TABLES - Static variable in class org.apache.flink.state.forst.ForStNativeMetricOptions
MONITOR_NUM_FILES_AT_LEVEL - Static variable in class org.apache.flink.state.forst.ForStNativeMetricOptions
MONITOR_NUM_IMMUTABLE_MEM_TABLES - Static variable in class org.apache.flink.state.forst.ForStNativeMetricOptions
MONITOR_NUM_LIVE_VERSIONS - Static variable in class org.apache.flink.state.forst.ForStNativeMetricOptions
MONITOR_NUM_RUNNING_COMPACTIONS - Static variable in class org.apache.flink.state.forst.ForStNativeMetricOptions
MONITOR_NUM_RUNNING_FLUSHES - Static variable in class org.apache.flink.state.forst.ForStNativeMetricOptions
MONITOR_NUM_SNAPSHOTS - Static variable in class org.apache.flink.state.forst.ForStNativeMetricOptions
MONITOR_SIZE_ALL_MEM_TABLES - Static variable in class org.apache.flink.state.forst.ForStNativeMetricOptions
MONITOR_STALL_MICROS - Static variable in class org.apache.flink.state.forst.ForStNativeMetricOptions
MONITOR_TOTAL_SST_FILES_SIZE - Static variable in class org.apache.flink.state.forst.ForStNativeMetricOptions

N

NumDeletesActiveMemTable - org.apache.flink.state.forst.ForStProperty
NumDeletesImmMemTables - org.apache.flink.state.forst.ForStProperty
NumEntriesActiveMemTable - org.apache.flink.state.forst.ForStProperty
NumEntriesImmMemTables - org.apache.flink.state.forst.ForStProperty
NumFilesAtLevel0 - org.apache.flink.state.forst.ForStProperty
NumFilesAtLevel1 - org.apache.flink.state.forst.ForStProperty
NumFilesAtLevel2 - org.apache.flink.state.forst.ForStProperty
NumFilesAtLevel3 - org.apache.flink.state.forst.ForStProperty
NumFilesAtLevel4 - org.apache.flink.state.forst.ForStProperty
NumFilesAtLevel5 - org.apache.flink.state.forst.ForStProperty
NumFilesAtLevel6 - org.apache.flink.state.forst.ForStProperty
NumImmutableMemTable - org.apache.flink.state.forst.ForStProperty
NumLiveVersions - org.apache.flink.state.forst.ForStProperty
NumRunningCompactions - org.apache.flink.state.forst.ForStProperty
NumRunningFlushes - org.apache.flink.state.forst.ForStProperty
NumSnapshots - org.apache.flink.state.forst.ForStProperty

O

offer(StateRequest<?, ?, ?>) - Method in class org.apache.flink.state.forst.ForStStateRequestClassifier
open(Path) - Method in class org.apache.flink.state.forst.fs.ForStFlinkFileSystem
open(Path, int) - Method in class org.apache.flink.state.forst.fs.ForStFlinkFileSystem
openDB(String, List<ColumnFamilyDescriptor>, List<ColumnFamilyHandle>, ColumnFamilyOptions, DBOptions) - Static method in class org.apache.flink.state.forst.ForStOperationUtils
OPTIONS_FACTORY - Static variable in class org.apache.flink.state.forst.ForStOptions: The options factory class for ForSt to create DBOptions and ColumnFamilyOptions.
org.apache.flink.state.forst - package org.apache.flink.state.forst
org.apache.flink.state.forst.fs - package org.apache.flink.state.forst.fs
org.apache.flink.state.forst.restore - package org.apache.flink.state.forst.restore

P

pollDbGetRequests() - Method in class org.apache.flink.state.forst.ForStStateRequestClassifier
pollDbPutRequests() - Method in class org.apache.flink.state.forst.ForStStateRequestClassifier
prepareDirectories() - Method in class org.apache.flink.state.forst.ForStResourceContainer: Prepare local and remote directories.
process() - Method in interface org.apache.flink.state.forst.ForStDBOperation: Process the ForStDB access requests.
process() - Method in class org.apache.flink.state.forst.ForStGeneralMultiGetOperation
process() - Method in class org.apache.flink.state.forst.ForStWriteBatchOperation

R

read() - Method in class org.apache.flink.state.forst.fs.ByteBufferReadableFSDataInputStream
read(byte[]) - Method in class org.apache.flink.state.forst.fs.ByteBufferReadableFSDataInputStream
read(byte[], int, int) - Method in class org.apache.flink.state.forst.fs.ByteBufferReadableFSDataInputStream
readFully(long, ByteBuffer) - Method in class org.apache.flink.state.forst.fs.ByteBufferReadableFSDataInputStream: Reads up to ByteBuffer#remaining bytes of data from the specific position of the input stream into a ByteBuffer.
readFully(ByteBuffer) - Method in class org.apache.flink.state.forst.fs.ByteBufferReadableFSDataInputStream: Reads up to ByteBuffer#remaining bytes of data from the input stream into a ByteBuffer.
REMOTE_DIRECTORY - Static variable in class org.apache.flink.state.forst.ForStOptions: The remote directory where ForSt puts its SST files.
rename(Path, Path) - Method in class org.apache.flink.state.forst.fs.ForStFlinkFileSystem
reset() - Method in class org.apache.flink.state.forst.fs.ByteBufferReadableFSDataInputStream
restore() - Method in class org.apache.flink.state.forst.restore.ForStNoneRestoreOperation
restore() - Method in interface org.apache.flink.state.forst.restore.ForStRestoreOperation: Restores state that was previously snapshot-ed from the provided state handles.

S

seek(long) - Method in class org.apache.flink.state.forst.fs.ByteBufferReadableFSDataInputStream
serializeKey(K) - Method in interface org.apache.flink.state.forst.ForStInnerTable: Serialize the given key to bytes.
serializeKey(ContextKey<K>) - Method in class org.apache.flink.state.forst.ForStValueState
serializeValue(V) - Method in interface org.apache.flink.state.forst.ForStInnerTable: Serialize the given value to the outputView.
serializeValue(V) - Method in class org.apache.flink.state.forst.ForStValueState
setColumnFamilyAsVariable(boolean) - Method in class org.apache.flink.state.forst.ForStNativeMetricOptions: Returns the column family as variable.
setFixedMemoryPerSlot(String) - Method in class org.apache.flink.state.forst.ForStMemoryConfiguration: Configures ForSt to use a fixed amount of memory shared between all instances (operators) in a slot.
setFixedMemoryPerSlot(MemorySize) - Method in class org.apache.flink.state.forst.ForStMemoryConfiguration: Configures ForSt to use a fixed amount of memory shared between all instances (operators) in a slot.
setForStOptions(ForStOptionsFactory) - Method in class org.apache.flink.state.forst.ForStStateBackend: Sets Options for the ForSt instances.
setHighPriorityPoolRatio(double) - Method in class org.apache.flink.state.forst.ForStMemoryConfiguration: Sets the fraction of the total memory to be used for high priority blocks like indexes, dictionaries, etc.
setLocalDbStoragePath(String) - Method in class org.apache.flink.state.forst.ForStStateBackend: Sets the path where the ForSt local files should be stored on the local file system.
setLocalDbStoragePaths(String...) - Method in class org.apache.flink.state.forst.ForStStateBackend: Sets the local directories in which the ForSt database puts some files (like metadata files).
setup(StateRequestHandler) - Method in class org.apache.flink.state.forst.ForStKeyedStateBackend
setUseManagedMemory(boolean) - Method in class org.apache.flink.state.forst.ForStMemoryConfiguration: Configures ForSt to use the managed memory of a slot.
setWriteBufferRatio(double) - Method in class org.apache.flink.state.forst.ForStMemoryConfiguration: Sets the fraction of the total memory to be used for write buffers.
shutdown() - Method in class org.apache.flink.state.forst.ForStStateExecutor
SizeAllMemTables - org.apache.flink.state.forst.ForStProperty
skip(long) - Method in class org.apache.flink.state.forst.fs.ByteBufferReadableFSDataInputStream
supportsAsyncKeyedStateBackend() - Method in class org.apache.flink.state.forst.ForStStateBackend
sync() - Method in class org.apache.flink.state.forst.fs.ByteBufferWritableFSDataOutputStream

T

TARGET_FILE_SIZE_BASE - Static variable in class org.apache.flink.state.forst.ForStConfigurableOptions
toString() - Method in class org.apache.flink.state.forst.ForStStateBackend
TotalSstFilesSize - org.apache.flink.state.forst.ForStProperty
TRACK_COMPACTION_PENDING - Static variable in class org.apache.flink.state.forst.ForStNativeMetricOptions

U

USE_BLOOM_FILTER - Static variable in class org.apache.flink.state.forst.ForStConfigurableOptions
USE_DYNAMIC_LEVEL_SIZE - Static variable in class org.apache.flink.state.forst.ForStConfigurableOptions
USE_MANAGED_MEMORY - Static variable in class org.apache.flink.state.forst.ForStOptions
USE_PARTITIONED_INDEX_FILTERS - Static variable in class org.apache.flink.state.forst.ForStOptions

V

validate() - Method in class org.apache.flink.state.forst.ForStMemoryConfiguration: Validates if the configured options are valid with respect to one another.
valueIsNull() - Method in class org.apache.flink.state.forst.ForStDBPutRequest
valueOf(String) - Static method in enum org.apache.flink.state.forst.ForStProperty: Returns the enum constant of this type with the specified name.
values() - Static method in enum org.apache.flink.state.forst.ForStProperty: Returns an array containing the constants of this enum type, in the order they are declared.

W

write(byte[]) - Method in class org.apache.flink.state.forst.fs.ByteBufferWritableFSDataOutputStream
write(byte[], int, int) - Method in class org.apache.flink.state.forst.fs.ByteBufferWritableFSDataOutputStream
write(int) - Method in class org.apache.flink.state.forst.fs.ByteBufferWritableFSDataOutputStream
write(ByteBuffer) - Method in class org.apache.flink.state.forst.fs.ByteBufferWritableFSDataOutputStream: Writes ByteBuffer#remaining bytes from the ByteBuffer to this output stream.
WRITE_BATCH_SIZE - Static variable in class org.apache.flink.state.forst.ForStConfigurableOptions
WRITE_BUFFER_RATIO - Static variable in class org.apache.flink.state.forst.ForStOptions
WRITE_BUFFER_SIZE - Static variable in class org.apache.flink.state.forst.ForStConfigurableOptions

A B C D E F G H I K L M N O P R S T U V W
All Classes All Packages