This operator can be used to publish processing results to multiple endpoints using different transport and application protocols.

Parameter

  • wrapper: In Odysseus the default wrappers are GenericPush and GenericPull
  • transport: The transport defines the transport protocol to use. See Transport handler
  • protocol: 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 handler
  • writeMetadata: 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
Sender Operator
output = SENDER({sink='Sink',
                 wrapper='GenericPush',
                 transport='TCPClient',
                 protocol='CSV',
                 dataHandler='Tuple',
                 options=[['host', 'example.com'],['port', '8081'],['read', '10240'],['write', '10240']]
                }, input)
CQL
Sender Operator
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:

  • No labels