...
ATTRIBUTES:The attributes from the store object, that should be used for enrichmentSTORE:The name of the storeOUTER: Enrich with null if the store is empty else the input is discarded.
Example
| Code Block | ||||||||
|---|---|---|---|---|---|---|---|---|
| ||||||||
output = ENRICH({store='StoreName', outer='true'}, input) |
EVENTTRIGGER
Description
Parameter
...
FILE:The filename to dump. If the path does not exist it will be created.FILETYPE:The type of file, CSV: Print as CSV, if not given, the element will be dump to file a raw format (JavatoString()-Method)
Example
JOIN
Description
Joins tuple from two input streams iff their timestamps are overlapping and if the optional predicate validates to true.
Parameter
predicate: The predicate to evaluate over each incoming tuple from left and right
...
socketsink({host='localhost', push=false, sinkport=4712, sinkType='bytebuffer', sinkName='driverChannel'}, timestampToPayload(person))STORE
Description
Transfer temporary information in a context store for use with the Enrich operator. More information about the context store can be found here.
Parameter
store: The name of the store
Example
| Code Block | ||||||||
|---|---|---|---|---|---|---|---|---|
| ||||||||
STORE({store = 'StoreName'}, input) |
TIMESTAMPTOPAYLOAD
Description
...