search

apache / rocketmq-streams

Apache rocketmq
https://rocketmq.apache.org/
Apache License 2.0
171 stars 82 forks source link

[ISSUE #73 #74] session window and count(distinct) implementation #79

Closed speak2me closed 3 years ago

speak2me commented 3 years ago

73 #74

  1. add implementation of session window and it's test
  2. add implementation of count(distinct) by using hyper-log-log algorithm and rocksDB, add test case in WindowTest
  3. fix some bug such substring function, hop window message etc
speak2me commented 3 years ago

70 #71 and this are the same

here I just have a try why i can't use travis-ci build 😅