...
Code Block | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
input = ACCESS({source='Source',
wrapper='GenericPull',
transport='HTTP',
protocol='CSV',
dataHandler='Tuple',
options=[['uri', 'http://www.example.com'], ['method', 'get']],
schema=[
['id', 'Double'],
['data', 'String']]
})
output = SENDER({sink='Sink',
wrapper='GenericPush',
transport='HTTP',
protocol='CSV',
dataHandler='Tuple',
options=[['uri', 'http://www.example.com'], ['method', 'post']]
}, input)
/// Example for the scheduler.delay option
#PARSER PQL
#ADDQUERY
web = ACCESS({
source='Google',
wrapper='GenericPull',
transport='HTTP',
protocol='Document',
datahandler='Document',
options=[
['uri', 'http://google.com'],
['scheduler.delay','1000'],
['oneDocPerCall','true'],
['contentType','application/json']
]
}
) |
CQL
Code Block | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
CREATE STREAM source (id Double, data STRING) WRAPPER 'GenericPush' PROTOCOL 'CSV' TRANSPORT 'HTTP' DATAHANDLER 'Tuple' OPTIONS ( 'uri' 'http://www.example.com' 'method' 'get') CREATE SINK sink (id Double, data STRING) WRAPPER 'GenericPush' PROTOCOL 'CSV' TRANSPORT 'HTTP' DATAHANDLER 'Tuple' OPTIONS ( 'uri' 'http://www.example.com' 'method' 'post') |