Page History

output = MAP({
              expressions = ['auction_id * 5','sqrt(auction_id)']
             }, input)

SELECT auction_id * 5, sqrt(auction_id) FROM input

output = PROJECT({
                  attributes = ['auction', 'bidder']
                 }, input)

SELECT auction, bidder FROM input

// Renames the first attribute to auction_id, the second to bidder_id and the last to another_id.
output = RENAME({
                  aliases = ['auction_id', 'bidder_id', 'another_id']
                 }, input)

// Due the set flag pairs, the rename operator renames the attribute auction_id to auction and bidder_id to bidder.
output = RENAME({
                 aliases = ['auction_id', 'auction', 'bidder_id', 'bidder'], 
                 pairs = 'true'
                }, input)

SELECT auction_id AS auction, bidder_id AS bidder FROM input

output = SELECT({ 
                 predicate=RelationalPredicate('price > 100') 
                }, input)

SELECT * FROM input WHERE price > 100

output = SENDER({sink='Sink',
                 wrapper='GenericPush',
                 transport='TCPClient',
                 protocol='CSV',
                 dataHandler='Tuple',
                 options=[['host', 'example.com'],['port', '8081'],['read', '10240'],['write', '10240']]
                }, input)

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 

output = UNION(left, right)

SELECT * FROM left UNION SELECT * FROM rigtht