feat(nebula): Add windowed value-union set-collect aggregates#54

Open

estebanzimanyi wants to merge 40 commits into

MobilityDB:mainfrom

estebanzimanyi:feat/nebula-codegen-w30-value-union-set-collect

Commits on Jun 11, 2026

fix(ci): make the Nix build work with NES_ENABLE_MEOS=OFF and stock paho-mqtt-cpp
estebanzimanyi
committed
feat(berlinmod): scaffold the full BerlinMOD-9 × 3-form parity matrix on NebulaStream (33 YAMLs, 27/27 cells)
estebanzimanyi
committed
feat(meos): TEMPORAL_LENGTH aggregation closes BerlinMOD-Q6 streaming-form cells to full
estebanzimanyi
committed
feat(meos): PAIR_MEETING + CROSS_DISTANCE aggregations close Q5 + Q9 streaming-form cells to full
estebanzimanyi
committed
docs(berlinmod): streaming-semantics tier overlay + remove stale 'Not covered' section
estebanzimanyi
committed
feat(meos): parameterize PAIR_MEETING dMeet via SQL constant fifth arg
estebanzimanyi
committed
feat(meos): parameterize CROSS_DISTANCE (vidA, vidB) via SQL constant args
estebanzimanyi
committed
tools(codegen): MEOS-operator generator + design proposal for Nebula codegen path
estebanzimanyi
committed
fix(meos): proto extra_fields + Werror unused-param in aggregations
estebanzimanyi
committed
feat(meos): W1 codegen output — 5 spatial-relation operators (tgeo × geom)
estebanzimanyi
committed
feat(meos): W2 codegen output — close the _tgeo_geo spatial-rel row
estebanzimanyi
committed
feat(meos): W3 codegen output — closes the _tgeo_tgeo spatial-rel row (9 ops)
estebanzimanyi
committed
feat(meos): W4 codegen — distance family (nad + dwithin, 5 ops + 2 templates)
estebanzimanyi
committed
feat(codegen): auto-inject parser glue — closes SQL loop for W1–W4 (20 dispatch cases)
estebanzimanyi
committed
feat(meos): W5a codegen — tnumber NAD ops (4 ops + 2 templates + 2 systests)
estebanzimanyi
committed
feat(meos): W6 codegen — tgeo restriction at/minus geom (2 ops + 1 template + 1 systest)
estebanzimanyi
committed
feat(meos): W7 codegen — windowed aggregations (12 ops + tools/codegen/codegen_aggregations.py + 2 systests)
estebanzimanyi
committed
feat(meos): W8 codegen — tnumber avg/twavg aggregations (3 ops, mechanical row-add)
estebanzimanyi
committed
feat(meos): W9 codegen — tgeo scalar accessors w/ new return types (5 ops; bool+int64)
estebanzimanyi
committed
feat(meos): W10 codegen — tcbuffer × geo spatial-rels (10 ops + 1 template + 1 systest)
estebanzimanyi
committed
feat(meos): W11 codegen — tcbuffer × cbuffer spatial-rels (10 ops + new template + 1 systest)
estebanzimanyi
committed
feat(meos): W12 codegen — tcbuffer × tcbuffer 2-arg spatial-rels (6 ops + 8-arg lift + 1 systest)
estebanzimanyi
committed
feat(meos): W13 codegen — tcbuffer dwithin family (6 ops + 3 with-dist templates + 1 systest)
estebanzimanyi
committed
feat(meos): W14 codegen — tpose × geo spatial-rels via composition (9 ops + 1 template + 1 systest)
estebanzimanyi
committed
feat(meos): W15 codegen — tpose × tpose spatial-rels via composition (9 ops + 1 template + 1 systest)
estebanzimanyi
committed
feat(meos): W18 codegen — tnpoint spatial-rels via composition (18 ops + 2 templates + 1 systest)
estebanzimanyi
committed
feat(meos): W19 codegen — tpose + tnpoint nad (nearest-approach distance) (4 ops + 1 systest)
estebanzimanyi
committed
feat(meos): W20 codegen — tpose + tnpoint dwithin (8 ops + 4 templates + 1 systest)
estebanzimanyi
committed
feat(meos): W21 codegen — tcbuffer nad (nearest-approach distance) (3 ops + 1 systest)
estebanzimanyi
committed
methodology(streaming): PROVEN MEOS-parity harness + type-aware callability (Flink/Kafka 100%)
estebanzimanyi
committed
feat(nebula): comparison family (60 operators) + signature-driven descriptor-builder
estebanzimanyi
committed
feat(nebula): W23 — 18 spatial-relation + comparison operators (existing templates)
estebanzimanyi
committed
feat(nebula): W24 — generalized per-event assembler + scalar families (165->214)
estebanzimanyi
committed
tools(nebula): build_local.sh — dev-image build with auto MQTT toggle
estebanzimanyi
committed
feat(nebula): W25 — extract marshaler for unary transforms (214->224)
estebanzimanyi
committed
feat(nebula): W26 — box/span family via per-event box-literals (224->243)
estebanzimanyi
committed
feat(nebula): W27 — windowed extent->box aggregates (VARSIZED) (243->245)
estebanzimanyi
committed
feat(nebula): W28 — value/time Span extent aggregates (scalar fold) (245->249)
estebanzimanyi
committed
feat(nebula): W29 — 55 box/temporal position predicates (per-event) (249->304)
estebanzimanyi
committed
feat(nebula): W30 — windowed value-union set-collect aggregates (304->309)
estebanzimanyi
committed