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
369 stars 80 forks source link

Windowed KStream missing some reduce #170

Closed deoqc closed 5 years ago

deoqc commented 5 years ago

Hello and thx for the great lib.

I have a window-by-time aggregation that works w/ reduce when this only has an adder. But, I need to also have a subtracter and this fails w/:

java.lang.AbstractMethodError: jackdaw.streams.interop.reduce

I believe that the signature of the reduce for CljTimeWindowedKStream is missing for this case.

Thx

deoqc commented 5 years ago

Mixed GroupedKStream w/ GroupedKTable. My bad.