Repository navigation

POC: Fusing repart and partial aggr - #12526

Closed

Rachelint wants to merge 34 commits into

apache:mainfrom

Rachelint:fusing-repart-and-partial-poc

Closed

POC: Fusing repart and partial aggr#12526
Rachelint wants to merge 34 commits into
apache:mainfrom
Rachelint:fusing-repart-and-partial-poc

Commits on Sep 14, 2024
- define PartitionedGroupValues trait.
  Rachelint
  committed
  e9792e2
Commits on Sep 16, 2024
- define `PartitionedGroupValues` and impl `PartitionedGroupValuesRows` for it.
  Rachelint
  committed
  25700eb
- introduce `PartitionedGroupValues` to main path, and fix compile.
  Rachelint
  committed
  d00e46b
Commits on Sep 17, 2024
- impl group_aggregate_batch_single serving for single hashtable.
  Rachelint
  committed
  855d454
- tmp
  Rachelint
  committed
  bae4f7f
Commits on Sep 18, 2024
- impl `group_aggregate_batch_partitioned`.
  Rachelint
  committed
  4f4441c
- tmp
  Rachelint
  committed
  f24f3c3
- impl `emit_partitioned`.
  Rachelint
  committed
  bec7a3a
Commits on Sep 19, 2024
- introduce `ExecutionState::ProducingPartitionedOutput` to process the partitioned outputs.
  Rachelint
  committed
  553c6a3
- introduce `PartitionedOutput`.
  Rachelint
  committed
  4108065
- use `PartitionedOutput`.
  Rachelint
  committed
  05f4a49
- fix panic.
  Rachelint
  committed
  39272a3
- fix aggr fuzz test.
  Rachelint
  committed
  0268404
- print partitioned.
  Rachelint
  committed
  bf83235
- debug.
  Rachelint
  committed
  5b68f1c
- fix.
  Rachelint
  committed
  45c9f86
- add debug log to inspect.
  Rachelint
  committed
  2fbcffc
- remove some dbg!.
  Rachelint
  committed
  a026b30
- check num partitions.
  Rachelint
  committed
  0d95981
- fix the hash seed in rows.
  Rachelint
  committed
  c91bc83
- debug finished.
  Rachelint
  committed
  abc59f6
- refactor `PartitionedGroupValuesRows`.
  Rachelint
  committed
  04756fa
- fix group indices.
  Rachelint
  committed
  33beb1c
- modify random state init.
  Rachelint
  committed
  ed8c4aa
- add partition info into schenma metadata.
  Rachelint
  committed
  540588d
- add fast partition in repart.
  Rachelint
  committed
  212641a
- debug finish.
  Rachelint
  committed
  9dee51f
- use the slice approach to convert group value rows.
  Rachelint
  committed
  0e1c33b
- fix compile.
  Rachelint
  committed
  cef63da
- fix partition num.
  Rachelint
  committed
  b69dfd2
- revert to old PartitionedGroupValuesRows.
  Rachelint
  committed
  cef6305
- revert the random state.
  Rachelint
  committed
  96e7e4b
Commits on Sep 21, 2024
- tmp
  Rachelint
  committed
  e9fe746
Commits on Sep 23, 2024
- remove some unused codes.
  Rachelint
  committed
  4d6f5e6

Commits

Commits on Sep 14, 2024

Commits on Sep 16, 2024

Commits on Sep 17, 2024

Commits on Sep 18, 2024

Commits on Sep 19, 2024

Commits on Sep 21, 2024

Commits on Sep 23, 2024