Advertisement
Guest User

Untitled

a guest
Jul 29th, 2015
220
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.32 KB | None | 0 0
  1. define my_super_stream every HOUR =
  2. parent_stream
  3. {
  4. string field1
  5. int field2
  6. int cnt = Sum(<<1>>) // Like count(*)
  7. }
  8.  
  9. define other_stream every HOUR = @anti_join
  10. {
  11. stream1
  12. {
  13. string field1
  14. }
  15. stream2 [DAY @ -HOUR] // window of 1 day and offset of - 1h
  16. {
  17. string field1
  18. }
  19. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement