This is an automated email from the ASF dual-hosted git repository.
hanahmily pushed a change to branch vectorized-query
in repository https://gitbox.apache.org/repos/asf/skywalking-banyandb.git
omit 07adc30db chore(scripts/soak): drop year-glob and remove eval in
soak-monitor.sh
omit 2c00450b7 perf(query/vectorized/measure): zero-alloc egress on nil
Selection + reuse null singletons
omit ad96b5aa9 fix(query/vectorized): correct Apply-after-Break stage
ordering in PipelineBuilder
omit d61e73dc2 Merge remote-tracking branch 'origin/main' into
vectorized-query
omit 475abf206 docs(changelog): note GroupBy+Agg coverage in vectorized
measure entry
omit a59dabeef fix(banyand/query): fall through to row path on emitPartial
GroupBy+Agg requests
omit 32fb720a3 feat(query/vectorized/measure)!: remove AggregationEnabled
flag — GroupBy+Agg dispatch is default-on
omit b750fa827 chore: fix lint issues
omit 4b54f1d4f test(query/integration): flip
--measure-vectorized-aggregation-enabled=true in parity gate (G8d.3)
omit 40fcf37b7 feat(query/vectorized/measure): BatchAggregation row-path
parity for MEAN type and non-key projected tags (G8d.3)
omit 348c09c29 fix(query/vectorized/measure/plan): thread GroupBy/Agg into
Scan schema so vec/storage column types agree (G8d.3)
omit 1cd7e768c docs(test/integration): record GroupBy+Agg bridge bug behind
vec aggregation flag (G8d.3)
omit 7c0d9259f fix(query/vectorized/measure): agg output column inherits
input field name for row-path parity (G8d.3 partial)
omit 0b079e752 feat(banyand/measure): plumb
--measure-vectorized-aggregation-enabled CLI flag (G8d.2)
omit ad9941657 feat(query/vectorized/measure/plan): flag-gated GroupBy+Agg
dispatch (G8d.2)
omit 253c56538 feat(query/vectorized/measure): BuildBatchSchema emits
native columns for GroupBy keys + Agg field (G8d.2)
omit 7117d9fa5 test(query/integration): assert vec dispatch fires in parity
gate (G8e)
omit c4e3ea866 feat(query/vectorized/measure/plan): dispatch eligibility
hardening + observability counters (G8e)
omit cf44971fd feat(banyand/query): wire vec dispatch into
executeMeasurePlan (G8d.2)
omit d71bc8890 feat(query/vectorized/measure/plan): vec dispatch entry
point (G8d.1)
omit bb1f75141 feat(query/vectorized/measure/plan): vec executor (G8c)
omit 84cdf6b8b feat(query/vectorized/measure): expose
NewIteratorFromPipeline
omit e55a6fa60 chore(query/measure): broaden row-path deprecation to all
primary plan types
omit 89900e661 feat(query/vectorized/measure/plan): vec analyzer (G8b)
omit bd9f9a08c feat(query/vectorized/measure/plan): VecPlan tree
scaffolding (G8a)
omit e2f30bda6 feat(query/vectorized): expose Pipeline.Init for multi-stage
cascades
omit d420fa893 chore(query/measure): mark row-path
Analyze/DistributedAnalyze as deprecated
omit 8008aa30f Revert "feat(query/vectorized/measure): wire aggregation
planner into NewMIterator (G7e)"
omit 275866aca feat(query/vectorized/measure): wire aggregation planner
into NewMIterator (G7e)
omit cb61bca97 feat(query/measure): MeasureGroupBy/Agg options and
BuildOperators planner (G7d)
omit 4a0479e86 feat(query/vectorized): shared per-pipeline MemoryTracker
(G7a)
omit 89c3119ff chore(measure): fix stale G5e config test and lint-blocking
typos
omit a0dc29e95 feat(measure): flip vectorized query path to enabled by
default (G5e)
omit 48c0f76be docs(soak): G5d Phase D summary
omit a9b77692f fix(soak): monitor tolerates missing Phase 0 files
omit 0c79de2ab feat(soak): tapered monitor for unattended G5d runs
omit 90aacda91 feat(banyand/measure): typed PullBatch for indexSortResult
(closes US-003 multi-block deferral)
omit 141aee43a docs(test): add CLAUDE.md with G5d soak-harness lessons
omit abedc3f06 feat(soak): G5d soak harness — docker-compose + soak-driver
+ runbook
omit 36140ca94 feat(banyand/measure): batch-aware multi-block merge for
PullBatch (US-003 strict completion)
omit d2b877ef3 test(banyand/measure): storage-level bench for block_cursor
decode (passthrough vs native)
omit 3560a960a test(query/vectorized/measure): realistic per-cell bench
fixture + multi-block workloads
omit b640c51a8 docs(query/vectorized/measure): pin passthrough as
production type + drop redundant deep-copy in batch source
omit b2d3c0802 feat(query/vectorized/measure): wire NewMIterator through
MeasureBatchResult.PullBatch (US-007 partial)
omit 55d3baf40 feat(banyand/measure): native typed-column emit on
blockCursor (US-003 strict, single-block fast path)
omit ba6e82787 feat(query/vectorized/measure): native typed-column dispatch
in BuildMeasureBatchFromResult (G5b/G5c partial)
omit a421813e1 feat(query/model): add MeasureBatchResult interface; storage
dual-emits (G5b foundation)
omit 5de3e0eb2 perf(query/vectorized/measure): close G5a gap via
passthrough columns + precomputed schema layout
omit 2614f0981 feat(query/vectorized/measure): add bench gates
infrastructure (gate G5a)
omit 0e0638741 test(integration): restore SharedContext in vectorized
parity AfterAll
omit fe9d38eb3 feat(query/vectorized/measure): add integration & parity
(gate G4)
omit 11d0f9884 chore: fix lint issues in vectorized/measure operators
omit 278b29490 feat(query/vectorized/measure): add operators + output (gate
G3)
omit 4e432ecb1 chore: fix lint issues in vectorized/measure package
omit 3755984c4 feat(query/vectorized/measure): add measure scan layer (gate
G2)
omit 3711bcee7 chore: fix lint issues in vectorized package
omit b39ed477b feat(query/vectorized): add vectorized pipeline foundation
(gate G1)
add 2804bdf87 feat: vectorized measure query subsystem (scan +
GroupBy+Agg) (#1129)
add af5970f0c fix(queue/pub): keep pub-node-probe alive after caller ctx
cancel (#1130)
new 8f21383d9 feat(query/vectorized/measure/plan): resolve order_by in vec
dispatch
new fedf8cf43 feat(query/vectorized/measure/plan): G9c boundary-error
parity (nil TimeRange, projection, empty result)
new 02d0c1940 feat(query/vectorized/measure/plan): G9d hidden criteria
tags egress-strip wrapper
new cadfec0bf feat(query/vectorized/measure/plan): G9b GroupBy/Agg
completeness (scalar reduce, raw GroupBy, projection auto-coverage)
new 9128d9fc2 feat(query/vectorized/measure/plan): G9a single-node Top
dispatch + analyzer sort-direction fix
new 2cb0ddcfe fix(query/vectorized/measure): COUNT preserves input type
for row-path parity (float_top_count)
new 087624546 chore(query/vectorized/measure/plan): fix goconst/dogsled
lint in G9 test files
new 768d67dd9 test(query/vectorized/measure/plan): rewrite stale G9b
fall-through tests + clarify empty-result hidden-strip skip
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (07adc30db)
\
N -- N -- N refs/heads/vectorized-query (768d67dd9)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 8 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
CHANGES.md | 2 +-
banyand/queue/pub/client.go | 8 +-
pkg/query/vectorized/measure/aggregation.go | 36 +-
pkg/query/vectorized/measure/groupby.go | 33 +-
pkg/query/vectorized/measure/plan.go | 46 +-
pkg/query/vectorized/measure/plan/analyzer.go | 135 ++++--
pkg/query/vectorized/measure/plan/analyzer_test.go | 143 +++++--
pkg/query/vectorized/measure/plan/build_test.go | 16 +-
pkg/query/vectorized/measure/plan/dispatch.go | 278 ++++++-------
pkg/query/vectorized/measure/plan/dispatch_test.go | 463 ++++++++++++++++-----
pkg/query/vectorized/measure/plan/executor_test.go | 123 +++++-
pkg/query/vectorized/measure/plan/groupby_agg.go | 39 +-
pkg/query/vectorized/measure/plan/hidden_tags.go | 94 +++++
pkg/query/vectorized/measure/plan/top.go | 8 +-
pkg/query/vectorized/measure/plan_test.go | 44 +-
pkg/query/vectorized/measure/top.go | 54 ++-
pkg/query/vectorized/measure/top_test.go | 44 ++
.../data/input/{tag_filter.ql => empty_result.ql} | 2 +-
...ter_non_existent_tag.yaml => empty_result.yaml} | 4 +-
...er_tag_asc.ql => project_non_existent_field.ql} | 4 +-
...nt_tag.yaml => project_non_existent_field.yaml} | 4 +-
test/cases/measure/measure.go | 2 +
.../standalone/query/vectorized_test.go | 10 +-
23 files changed, 1175 insertions(+), 417 deletions(-)
create mode 100644 pkg/query/vectorized/measure/plan/hidden_tags.go
copy test/cases/measure/data/input/{tag_filter.ql => empty_result.ql} (96%)
copy test/cases/measure/data/input/{filter_non_existent_tag.yaml =>
empty_result.yaml} (94%)
copy test/cases/measure/data/input/{order_tag_asc.ql =>
project_non_existent_field.ql} (91%)
copy test/cases/measure/data/input/{project_non_existent_tag.yaml =>
project_non_existent_field.yaml} (93%)
