Package | Description |
---|---|
org.apache.flink.contrib.streaming.state |
Modifier and Type | Method and Description |
---|---|
default RocksDBNativeMetricOptions |
OptionsFactory.createNativeMetricsOptions(RocksDBNativeMetricOptions nativeMetricOptions)
This method should enable certain RocksDB metrics to be forwarded to
Flink's metrics reporter.
|
static RocksDBNativeMetricOptions |
RocksDBNativeMetricOptions.fromConfig(Configuration config)
Creates a
RocksDBNativeMetricOptions based on an
external configuration. |
RocksDBNativeMetricOptions |
RocksDBStateBackend.getMemoryWatcherOptions() |
Modifier and Type | Method and Description |
---|---|
default RocksDBNativeMetricOptions |
OptionsFactory.createNativeMetricsOptions(RocksDBNativeMetricOptions nativeMetricOptions)
This method should enable certain RocksDB metrics to be forwarded to
Flink's metrics reporter.
|
Constructor and Description |
---|
RocksDBKeyedStateBackend(String operatorIdentifier,
ClassLoader userCodeClassLoader,
File instanceBasePath,
org.rocksdb.DBOptions dbOptions,
org.rocksdb.ColumnFamilyOptions columnFamilyOptions,
TaskKvStateRegistry kvStateRegistry,
TypeSerializer<K> keySerializer,
int numberOfKeyGroups,
KeyGroupRange keyGroupRange,
ExecutionConfig executionConfig,
boolean enableIncrementalCheckpointing,
LocalRecoveryConfig localRecoveryConfig,
RocksDBStateBackend.PriorityQueueStateType priorityQueueStateType,
TtlTimeProvider ttlTimeProvider,
RocksDBNativeMetricOptions metricOptions,
MetricGroup metricGroup) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.