This operator enriches tuples with data that is cached, e.g. to enrich a stream with a list of categories. The first input stream, therefore, should be only stream limited data to avoid buffer overflows. The second input is the data stream that should be enriched.
Parameter
PREDICATE: A predicate that is used for lookup and joining.MINIMUMSIZE: Blocks the streaming input until there are at least MINIMUMSIZE elements in the cache from the static stream . Can be used to assure that all static data is loaded before it is used for enriching the other stream. This parameter is optional, the default value is 0, so that it is immediately tried to enrich.
Example
| Code Block |
|---|
| theme | Eclipse |
|---|
| language | javascript |
|---|
| title | Enrich Operator |
|---|
| linenumbers | true |
|---|
|
output = ENRICH({MINIMUMSIZE = 42, PREDICATE = 'sensorid = sid'}, metadata, input) |