Skip to content

feat: parallel-aware ungrouped vectorized batch fold (#289 phase 5/6) #343

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
jdatcmd merged 4 commits into from
Aug 3, 2026
Merged

feat: parallel-aware ungrouped vectorized batch fold (#289 phase 5/6) #343

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
f01ec56
feat: parallel-aware ungrouped vectorized batch fold (#289 phase 5/6)
ChronicallyJD Aug 3, 2026
a560939
test: parallel_vector_agg harness form + register in run_all_versions
ChronicallyJD Aug 3, 2026
8ea5ff8
fix: build avg(float8) partial array with construct_array, not _builtin
ChronicallyJD Aug 3, 2026
97ebc5a
test: cover parallel fold with deletes, incl. the H2 in-xact case
ChronicallyJD Aug 3, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions src/columnar.h
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -176,6 +176,7 @@ extern bool columnar_enable_bloom_filter; /* bloom equality skipping (I7) */
extern bool columnar_enable_vectorization; /* vectorized aggregate path */
extern bool columnar_enable_group_vectorization; /* GROUP BY vectorized agg (#289) */
extern bool columnar_enable_ungrouped_vector_agg; /* filtered/extended ungrouped agg (#289) */
extern bool columnar_enable_parallel_vector_agg; /* parallel-aware ungrouped batch fold (#289 phase 5/6) */
extern int columnar_groupagg_max_groups; /* plan-time group-count cap (#289) */
extern bool columnar_enable_read_stream; /* stream/prefetch block reads (PG17+) */
extern bool columnar_enable_index_only_scan; /* allow index-only scans (gap 28) */
Expand Down
11 changes: 11 additions & 0 deletions src/columnar_tableam.c
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2278,6 +2278,17 @@ _PG_init(void)
0,
NULL, NULL, NULL);

DefineCustomBoolVariable("pgcolumnar.enable_parallel_vector_agg",
"Make the ungrouped vectorized batch fold parallel-aware: "
"each worker folds distinct row groups and emits a partial "
"aggregate a core Finalize combines.",
NULL,
&columnar_enable_parallel_vector_agg,
false,
PGC_USERSET,
0,
NULL, NULL, NULL);

DefineCustomIntVariable("pgcolumnar.groupagg_max_groups",
"Cap on the actual group count the grouped vectorized "
"aggregate builds before it stops with an error.",
Expand Down
Loading
Loading