StreamGraph::setConfigMap
Syntax
StreamGraph::setConfigMap(dict)
Arguments
dict is a dictionary, supporting the following key-value pairs:
Key | Type | Default Value | Description |
---|---|---|---|
subscription.batchSize | INT | 0 | Sets the batchSize parameter for all subscriptions in the stream graph. |
subscription.throttle | INT | 1 | Sets the throttle parameter for all subscriptions in the stream graph. |
subscription.timeTrigger | BOOL | false | Enables or disables timeTrigger for all subscriptions in the stream graph. |
privateTable.cacheSize | INT | 1000 | Sets the cacheSize parameter of all private stream tables with persistence enabled. |
Details
Used to configure private stream tables and subscriptions within a stream
graph.During the stream graph creation process, the system automatically adds
private stream tables and subscriptions for data redistribution (shuffle). These
components do not require manual declaration. To modify the runtime parameters of
these auto-generated components, you can pass configuration items via
setConfigMap
.
Examples
if (!existsCatalog("orca")) {
createCatalog("orca")
}
go
use catalog orca
g = createStreamGraph("orca")
.setConfigMap({
"subscription.throttle": 1,
"privateTable.cacheSize": 1000
})