Open focusaurus opened 4 years ago
If I put the 5-arg version of this into my topology:
(j/aggregate groupedstream tree-agg-init tree-agg-add tree-agg-subtract agg-topic)
I get an exception:
Execution error (AbstractMethodError) at jackdaw.streams/aggregate (streams.clj:260). jackdaw.streams.interop.CljKGroupedStream.aggregate(Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
I believe that although a 5-arity version is defined in streams.clj here, there's no corresponding interop for it here
streams.clj
My workaround is not to pass the subtractor fn arg which is the 4-arity flavor which works OK.
If I put the 5-arg version of this into my topology:
I get an exception:
I believe that although a 5-arity version is defined in
streams.cljhere, there's no corresponding interop for it hereMy workaround is not to pass the subtractor fn arg which is the 4-arity flavor which works OK.