Dynamic Configuration
Many of the Streambased configuration properties related to indexing and Kafka sources can also be configured using specialist SQL at runtime.
The following configuration objects can be modified:
Sources
Extractors
Transformers
Aggregators
Listing configuration objects
Configurations can be listed via the following syntax:
SHOW STREAMBASED [SOURCE/EXTRACTOR/TRANSFORMER/AGGREGATOR]
Adding/Modifying a new configuration object
Configurations can be added or updated via the following syntax:
[CREATE/UPDATE] STREAMBASED [SOURCE/EXTRACTOR/TRANSFORMER/AGGREGATOR] [config object name] WITH [json payload]
Where config object name
is the name of the Source/Extractor/Transformer/Aggregator you are working with and json payload
contains un-prefixed versions of the properties described here. e.g.:
{
"source" : "someKafka",
"topic" : "someTopic",
"class" : "com.example.someExtractor"
}
Deleting a configuration object
Configurations can be deleted via the following syntax:
DROP STREAMBASED [SOURCE/EXTRACTOR/TRANSFORMER/AGGREGATOR] [config object name]
Where config object name
is the name of the Source/Extractor/Transformer/Aggregator you are working with.
Last updated