The JSON protocol handler parses JSON documents.
none
input = ACCESS({source='JSON', wrapper='GenericPush',
transport='File',protocol='JSON',
dataHandler='Tuple',options=[],
schema=[
['symbol','String'],
['points','Double'] ]
}) |
CREATE STREAM line (symbol String, points Double) WRAPPER 'GenericPush' PROTOCOL 'JSON' TRANSPORT 'File' DATAHANDLER 'Tuple' |