Windowed KStream missing some reduce
Closed this issue · 1 comments
deoqc commented
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
Mixed GroupedKStream
w/ GroupedKTable
. My bad.