Code

Implement tumbling_count_window#709

Code

Draft

quentin-quix wants to merge 38 commits intomainquixio/quix-streams:mainfrom quent/couting-windowquixio/quix-streams:quent/couting-windowCopy head branch name to clipboard

+2,056-666

Commits

Commits on Jan 7, 2025

• Remove unnecessary value from docstring

  gwaramadze

  committed
  439d59c

  Copy full SHA for 439d59c

• Rename encode_window_prefix to a more generic append_integer

  gwaramadze

  committed
  9d09794

  Copy full SHA for 9d09794

• Invert condition in expire_windows

  gwaramadze

  committed
  4d66c66

  Copy full SHA for 4d66c66

• Move max window timestamp logic from state to window

  gwaramadze

  committed
  9238816

  Copy full SHA for 9238816

• Reorder value and timestamp_ms arguments for consistency

  gwaramadze

  committed
  3ca19fb

  Copy full SHA for 3ca19fb

• Extract _get_items from get_windows method

  gwaramadze

  committed
  67c4133

  Copy full SHA for 67c4133

• Clarify typing in window definitions

  gwaramadze

  committed
  e40c67b

  Copy full SHA for e40c67b

• Reorder arguments in FixedTimeWindow

  gwaramadze

  committed
  b922c69

  Copy full SHA for b922c69

• Create collect aggregation function and pass aggregate_collection arg

  gwaramadze

  committed
  6568c92

  Copy full SHA for 6568c92

• Correct typing in serialization.py

  gwaramadze

  committed
  c921fab

  Copy full SHA for c921fab

• Rename PREFIX_SEPARATOR to SEPARATOR

  gwaramadze

  committed
  bca82e3

  Copy full SHA for bca82e3

• Remove redundant cast to list

  gwaramadze

  committed
  13c424d

  Copy full SHA for 13c424d

• Feature: Collection Aggregations

  gwaramadze

  committed
  94958a7

  Copy full SHA for 94958a7

• Add latest deleted value cache

  gwaramadze

  committed
  772cee9

  Copy full SHA for 772cee9

• Set last deleted value timestamp

  gwaramadze

  committed
  d270dbe

  Copy full SHA for d270dbe

• Minor fixes in sliding windows tests

  gwaramadze

  committed
  51ffff7

  Copy full SHA for 51ffff7

• Make sliding windows tests specific for reduce aggregation function

  gwaramadze

  committed
  b5d1a01

  Copy full SHA for b5d1a01

• Deserialize and re-serialize key when deleting value

  Show description for bf6ba05
  gwaramadze

  committed
  bf6ba05

  Copy full SHA for bf6ba05

• Correct _get_items documentation

  Show description for 53e46dc
  gwaramadze

  committed
  53e46dc

  Copy full SHA for 53e46dc

• Return empty list if the start is higher than the end

  Show description for ce43ee8
  gwaramadze

  committed
  ce43ee8

  Copy full SHA for ce43ee8

• Add collection aggregation sliding windows test

  gwaramadze

  committed
  189c947

  Copy full SHA for 189c947

• Helper variable in FixedTimeWindow.process_window

  gwaramadze

  committed
  85937f0

  Copy full SHA for 85937f0

• Fix mypy

  gwaramadze

  committed
  540593f

  Copy full SHA for 540593f

• Add test_collect_value

  gwaramadze

  committed
  165117f

  Copy full SHA for 165117f

• Add test_delete_windows_with_values

  gwaramadze

  committed
  2fbcec4

  Copy full SHA for 2fbcec4

• Add test_expire_windows_with_collect

  gwaramadze

  committed
  35b500a

  Copy full SHA for 35b500a

Commits on Jan 8, 2025

• Add test_tumblingwindow_collect

  gwaramadze

  committed
  7aeac33

  Copy full SHA for 7aeac33

• Add test_hoppingwindow_collect

  gwaramadze

  committed
  b3ccbcd

  Copy full SHA for b3ccbcd

• Fix docstrings and comments

  gwaramadze

  committed
  0c57882

  Copy full SHA for 0c57882

• Add entry in windowing documentation

  gwaramadze

  committed
  6bc781b

  Copy full SHA for 6bc781b

Commits on Jan 10, 2025

• Ensure that values coming at the same time are collected in correct order

  gwaramadze

  committed
  b7a3c83

  Copy full SHA for b7a3c83

Commits on Jan 15, 2025

• Update mkdocs.yml (#703)

  Show description for ab7f362
  

  gwaramadze

  authored and

  quentin-quix

  committed
  ab7f362

  Copy full SHA for ab7f362

• Switch to "range" assignor strategy from "cooperative-sticky" (#705)

  Show description for d0c846a
  

  2 peopleauthored and

  quentin-quix

  committed
  d0c846a

  Copy full SHA for d0c846a

• Update documentation (#699)

  Show description for 9075547
  

  2 peopleauthored and

  quentin-quix

  committed
  9075547

  Copy full SHA for 9075547

• Implement tumbling_count_window

  quentin-quix

  committed
  9156c00

  Copy full SHA for 9156c00

Commits on Jan 16, 2025

• rebase on collection aggregation

  quentin-quix

  committed
  7a6d11f

  Copy full SHA for 7a6d11f

• keep tumbling_window

  quentin-quix

  committed
  5058678

  Copy full SHA for 5058678

• TestCountTumblingWindow

  quentin-quix

  committed
  65bf164

  Copy full SHA for 65bf164