...
uri:
The URImethod
: The HTTP method, one of: GET, POST, PUT, DELETE, HEAD (default: GET) (optional)body
: The content for POST and PUT requests when using this transport handler for a source (optional)- chunked: Controls the 'chunked' header (see Chunked transfer encoding). (default: true) (optional)
Example
PQL
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) |
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') |