Uses of Class
org.apache.flink.state.forst.ForStNativeMetricOptions

Packages that use ForStNativeMetricOptions

Package	Description
org.apache.flink.state.forst
org.apache.flink.state.forst.restore
org.apache.flink.state.forst.sync

Uses of ForStNativeMetricOptions in org.apache.flink.state.forst

Methods in org.apache.flink.state.forst that return ForStNativeMetricOptions

Modifier and Type	Method	Description
default ForStNativeMetricOptions	ForStOptionsFactory.createNativeMetricsOptions(ForStNativeMetricOptions nativeMetricOptions)	This method should enable certain ForSt metrics to be forwarded to Flink's metrics reporter.
static ForStNativeMetricOptions	ForStNativeMetricOptions.fromConfig(org.apache.flink.configuration.ReadableConfig config)	Creates a ForStNativeMetricOptions based on an external configuration.

Methods in org.apache.flink.state.forst with parameters of type ForStNativeMetricOptions

Modifier and Type	Method	Description
default ForStNativeMetricOptions	ForStOptionsFactory.createNativeMetricsOptions(ForStNativeMetricOptions nativeMetricOptions)	This method should enable certain ForSt metrics to be forwarded to Flink's metrics reporter.

Constructors in org.apache.flink.state.forst with parameters of type ForStNativeMetricOptions

Constructor	Description
ForStNativeMetricMonitor(ForStNativeMetricOptions options, org.apache.flink.metrics.MetricGroup metricGroup, org.forstdb.RocksDB rocksDB, org.forstdb.Statistics statistics)

Uses of ForStNativeMetricOptions in org.apache.flink.state.forst.restore

Constructors in org.apache.flink.state.forst.restore with parameters of type ForStNativeMetricOptions

Constructor	Description
ForStHeapTimersFullRestoreOperation(org.apache.flink.runtime.state.KeyGroupRange keyGroupRange, int numberOfKeyGroups, ClassLoader userCodeClassLoader, Map<String,ForStOperationUtils.ForStKvStateInfo> kvStateInformation, LinkedHashMap<String,org.apache.flink.runtime.state.heap.HeapPriorityQueueSnapshotRestoreWrapper<?>> registeredPQStates, org.apache.flink.runtime.state.heap.HeapPriorityQueueSetFactory priorityQueueFactory, org.apache.flink.runtime.state.StateSerializerProvider<K> keySerializerProvider, org.apache.flink.core.fs.Path instanceRocksDBPath, org.forstdb.DBOptions dbOptions, Function<String,org.forstdb.ColumnFamilyOptions> columnFamilyOptionsFactory, ForStNativeMetricOptions nativeMetricOptions, org.apache.flink.metrics.MetricGroup metricGroup, ForStDBTtlCompactFiltersManager ttlCompactFiltersManager, long writeBatchSize, Long writeBufferManagerCapacity, Collection<org.apache.flink.runtime.state.KeyedStateHandle> restoreStateHandles, org.apache.flink.core.fs.ICloseableRegistry cancelStreamRegistryForRestore)
ForStIncrementalRestoreOperation(String operatorIdentifier, org.apache.flink.runtime.state.KeyGroupRange keyGroupRange, int keyGroupPrefixBytes, org.apache.flink.core.fs.CloseableRegistry cancelStreamRegistry, ClassLoader userCodeClassLoader, Map<String,ForStOperationUtils.ForStKvStateInfo> kvStateInformation, org.apache.flink.runtime.state.StateSerializerProvider<K> keySerializerProvider, ForStResourceContainer optionsContainer, org.apache.flink.core.fs.Path forstBasePath, org.apache.flink.core.fs.Path instanceRocksDBPath, org.forstdb.DBOptions dbOptions, Function<String,org.forstdb.ColumnFamilyOptions> columnFamilyOptionsFactory, ForStNativeMetricOptions nativeMetricOptions, org.apache.flink.metrics.MetricGroup metricGroup, ForStDBTtlCompactFiltersManager ttlCompactFiltersManager, long writeBatchSize, Long writeBufferManagerCapacity, org.apache.flink.runtime.state.StateBackend.CustomInitializationMetrics customInitializationMetrics, Collection<org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandle> restoreStateHandles, double overlapFractionThreshold, boolean useIngestDbRestoreMode, boolean useDeleteFilesInRange, org.apache.flink.core.execution.RecoveryClaimMode recoveryClaimMode, Function<org.apache.flink.runtime.state.metainfo.StateMetaInfoSnapshot,org.apache.flink.runtime.state.RegisteredStateMetaInfoBase> stateMetaInfoFactory)
ForStNoneRestoreOperation(Map<String,ForStOperationUtils.ForStKvStateInfo> kvStateInformation, org.apache.flink.core.fs.Path instanceRocksDBPath, org.forstdb.DBOptions dbOptions, Function<String,org.forstdb.ColumnFamilyOptions> columnFamilyOptionsFactory, ForStNativeMetricOptions nativeMetricOptions, org.apache.flink.metrics.MetricGroup metricGroup, ForStDBTtlCompactFiltersManager ttlCompactFiltersManager, long writeBatchSize, Long writeBufferManagerCapacity)

Uses of ForStNativeMetricOptions in org.apache.flink.state.forst.sync

Methods in org.apache.flink.state.forst.sync with parameters of type ForStNativeMetricOptions

Modifier and Type	Method	Description
ForStSyncKeyedStateBackendBuilder<K>	ForStSyncKeyedStateBackendBuilder.setNativeMetricOptions(ForStNativeMetricOptions nativeMetricOptions)