Parameter

  • time: The time (in ms) this operator should wait before each element is sent to the next operator.


Example

#PARSER PQL
#ADDQUERY
bidsWindow = TIMEWINDOW({
                  size=[80, 'MILLISECONDS'],
                  advance=[80, 'MILLISECONDS']
                },
                bid
              )
              
sleep = SLEEP({TIME = 1000}, bidsWindow)


same can be done with the map function sleep

map = MAP({EXPRESSIONS = ['sleep(1000)']}, buffer)
  • No labels