search

FundingCircle / jackdaw

A Clojure library for the Apache Kafka distributed streaming platform.
https://fundingcircle.github.io/jackdaw/
BSD 3-Clause "New" or "Revised" License
368 stars 80 forks source link

new sliding window by time function #374

Open sorumehta opened 1 month ago

sorumehta commented 1 month ago

Implemented a new sliding window function in the existing IKGroupedStream protocol. I used a simple approach here. Instead of accepting window instance, I am just accepting window time and grace, and creating SlidingWindows instance internally.

kidpollo commented 1 month ago

Dont forget to add tests :D https://github.com/FundingCircle/jackdaw/blob/master/test/jackdaw/streams_test.clj