...
| Code Block | ||
|---|---|---|
| ||
tupleToKeyValue = TUPLETOKEYVALUE({type='KEYVALUEOBJECT'}, receiverTuple) |
Select
| Code Block | ||
|---|---|---|
| ||
selectJSON = SELECT({predicate='track.artist.name = "Evanescence"'}, receiverJSON)
selectJSONList = SELECT({predicate='timestamp.unixtimestamp[0] = 1162304033'}, receiverJSON) |
...
| Code Block | ||
|---|---|---|
| ||
SENDERjson = SENDER({
transport='File',
wrapper='GenericPush',
protocol='JSON',
dataHandler='KeyValueObject',
SINK="SENDERjson",
options=[['filename','${WORKSPACEPROJECT}\output\test2'],
['json.write.metadata','true'],
['json.write.starttimestamp','metadata.starttimestamp'],
['json.write.endtimestamp','metadata.endtimestamp'] ]
}, json) |
Transfer data with JSON
...