Page History

// 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 = renameRENAME({
                 aliases = ['auction_id', 'auction', 'bidder_id', 'bidder'], 
                 pairs = 'true'
                }, input)

output = unnestUNNEST({
                 attribute='myAttribute'
                },input)

output = udoUDO({
              class='MyUDO', 
              init='some parameter'}, 
             }, input)

//sliding time window
 output = windowWINDOW({
                  size = 5, 
                  advance = 1, 
                  type = 'time'
                 }, input)

 //sliding tuple window partioniert ueber bidder
 output = windowWINDOW({size
 = 5, advance = 1, type = 'tuple', partition=['bidder']              size = 5, 
                  advance = 1, 
                  type = 'tuple', 
                  partition=['bidder']
                 }, input) 

 //unbounded window
 output = WINDOW({
                  type = 'unbounded'
                 }, input) 

 //now window (size = 1, advance = 1)
 output = WINDOW({
                  type = 'time'
                 }, input) 

 //unboundedsliding delta window, reduces time granularity to value of slide
 output = windowWINDOW({type = 'unbounded'}, input) 

 //now window (
                  size = 1, advance = 1)
 output = window({5, 
                  type = 'time'}, input)

 //sliding delta window, reduces time granularity to value of slide
 output = window({size = 5, type = 'time', slide = 5
                  slide = 5
                 }, input)

 // Predicate window
 output = windowWINDOW({
                  startCondition=RelationalPredicate('a>10'), 
                  endCondition = RelationalPredicate('a<10')
                 }, input)