...
| Code Block | ||||||||
|---|---|---|---|---|---|---|---|---|
| ||||||||
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:
| Children Display |
|---|