I have been looking for implementation of Deterministic wave introduced by Gibbons et al.[1]. This a useful algorithm for computing many important information over data streams in sliding window. The algorithm finds the number of 1's in a bit stream over sliding window. However, it can be adopted for many other useful statistics of data streams. I tried many data stream libraries like MOA, Streaminer, etc but could not found any help.
Is there any other opensource stream processing library that has implementation of Deterministic waves?
[1] Gibbons, Phillip B., and Srikanta Tirthapura. "Distributed streams algorithms for sliding windows." Proceedings of the fourteenth annual ACM symposium on Parallel algorithms and architectures. ACM, 2002.