Package | Description |
---|---|
org.apache.flink.contrib.streaming.state |
Modifier and Type | Interface and Description |
---|---|
interface |
ConfigurableOptionsFactory
An interface for options factory that pick up additional parameters from a configuration.
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultConfigurableOptionsFactory
An implementation of
ConfigurableOptionsFactory using options provided by RocksDBConfigurableOptions
and acted as the default options factory within RocksDBStateBackend if user not defined a OptionsFactory . |
Modifier and Type | Method and Description |
---|---|
OptionsFactory |
ConfigurableOptionsFactory.configure(Configuration configuration)
Creates a variant of the options factory that applies additional configuration parameters.
|
OptionsFactory |
RocksDBStateBackend.getOptions()
Gets the options factory that lazily creates the RocksDB options.
|
Modifier and Type | Method and Description |
---|---|
void |
RocksDBStateBackend.setOptions(OptionsFactory optionsFactory)
Sets
Options for the RocksDB instances. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.