Page tree
Skip to end of metadata
Go to start of metadata

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 
  • No labels