...
wrapper:
In Odysseus the default wrappers are GenericPush and GenericPulltransport:
The transport defines the transport protocol to use. See Transport handlerprotocol:
The protocol parameter defines the application protocol to transform the processing results. See Protocol handler
datahandler:
This parameter defines the transform of the single attributes of the processing results. See Data handlerwriteMetadata
: If set to true, the meta data of the object will be written to the output, too. Default (false) (Works currently only in PQL)options:
Transport protocol and application protocol depending options (See Transport handler and Protocol handler)
Example
PQL
Code Block |
---|
language | javascript |
---|
theme | Eclipse |
---|
title | Sender Operator |
---|
linenumbers | true |
---|
|
output = SENDER({sink='Sink',
wrapper='GenericPush',
transport='TCPClient',
protocol='CSV',
dataHandler='Tuple',
options=[['host', 'example.com'],['port', '8081'],['read', '10240'],['write', '10240']]
}, input) |
...
Code Block |
---|
language | sql |
---|
theme | Eclipse |
---|
title | Sender Operator |
---|
linenumbers | true |
---|
|
CREATE SINK outSink (timestamp STARTTIMESTAMP, auction INTEGER, bidder INTEGER, datetime LONG, price DOUBLE)
WRAPPER 'GenericPush'
PROTOCOL 'CSV'
TRANSPORT 'TCPClient'
DATAHANDLER 'Tuple'
OPTIONS ( 'host' 'example.com', 'port' '8081', 'read' '10240', 'write' '10240' )
STREAM TO sink SELECT * FROM input |
There are some special operators based on this operator with an easier handling of parameters: