Page History

...

output = AGGREGATE({
                    group_by = ['bidder'], 
                    aggregations=[ ['MAX', 'price', 'max_price', 'double'] ]
                   }, input)

ASSUREHEARTBEAT

...

• Predicate: The predicate

• Type: Either EXISTS or NOT_EXISTS


Example

output = EXISTENCE({
                    type='EXISTS', predicate=RelationalPredicate('auction = auction_id') 
                    predicate=RelationalPredicate('auction = auction_id')
                   }, left, right)

output = EXISTENCE({
                    type='NOT_EXISTS', 
                    predicate=RelationalPredicate('auction = auction_id')}, left, right)
                   }, left, right)

FILESINK

Description

The operator can be used to dump the results of an operator to a file.

...

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

SASE

Description

...

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

PUNCTUATION

Description

...

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

// 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)

ROUTE

Description

This operator can be used to route the elements in the stream to different further processing operators, depending on the predicate.

...