The JSON protocol handler parses JSON documents.
none
json = ACCESS({ source='json', wrapper='GenericPull', transport='File', protocol='JSON', dataHandler='KeyValueObject', options=[['filename','scrobbles-2006-10.json']] }) |
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' |