...
Code Block | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
CREATE SINK sink (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 |
SINK
Description
Parameter
Example
...