Skip to content

Cumulative v2

Fabian Kaelin requested to merge cumulative_v2 into main

Re-design cumulative decaying operator

  • input stream is multi-plexed and aggregated using different grouping and count-min-sketch logic (e.g. per key, per country, per isp, per base_url)
  • resulting partial cumulative are joined in custom operator
  • reduces the number of count-min-sketches to one per aggregation, which can be individually configured

Merge request reports