feat(berlinmod): route the streaming parity matrix through MEOS via JMEOS 1.4 (stacks on #1)#14
Open
estebanzimanyi wants to merge 2 commits into
Conversation
This was referenced Jun 11, 2026
Closed
Closed
estebanzimanyi
force-pushed
the
feat/berlinmod-q1-scaffold
branch
from
346999a to
5e64f44
Compare
…MEOS 1.4
The BerlinMOD-9 × 3-form processors route their spatial predicates and
distances through MEOS (libmeos via the JMEOS 1.4 bridge) instead of the
pure-Java Haversine/SegmentDistance fallbacks: edwithin / eintersects /
geog_distance and the set-set join family.
Adds the MEOS Kafka-Streams DSL-tier wirings (stateless / bounded-state /
windowed / cross-stream), per-family MEOS facade smoke tests (cbuffer /
npoint / pose), a set-set spatial-join verification test, the parameterized
topology builder, and the canonical BerlinMOD corpus loader. The inherited
full-matrix test now routes through MEOS; the lone engine-divergent cell is
Q5 ("pairs meeting"), gated on the meos.enabled flag.
kafka-streams-test-utils stays test-scoped; the MEOS smoke tests run in their
own JVM fork (reuseForks=false) because MEOS keeps process-global state that
cannot be re-initialised after meos_finalize.
estebanzimanyi
force-pushed
the
consolidate/kafka-meos-integration
branch
from
c6f2016 to
6305403
Compare
… surface Rebuild the bundled JMEOS jar from the regenerated JMEOS surface: the hand-rolled functions.functions facade is gone, GeneratedFunctions carries the sret-bound by-value struct returns (the *Split family) and the collation-init fix, the org.mobilitydb.meos MeosOps* facade is regenerated against it, and the MeosSetSetJoin helper rides the set-set spatial-join surface. Verified: kafka-streams-app compiles and its test suite is green (11 tests, 0 failures) against the refreshed jar.
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
1 participant
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
Path-B consolidation — PR 2 of 3 (scaffold #1 · MEOS integration · benchmark).
Collapses the former MEOS stack (old #2–#10) into one topical commit on top of the reviewed scaffold #1. Routes the BerlinMOD-9 × 3-form processors through MEOS (libmeos via the JMEOS 1.4 bridge) —
edwithin_tgeo_geo,eintersects_tgeo_geo,geog_distance, and the set-set join family — and adds the MEOS DSL-tier wirings + per-family facade smoke tests + the canonical BerlinMOD corpus loader.Irregularities removed vs. the old stack
jar/JMEOS.jar); the old stack added ~127k generated lines then deleted them.meos/MeosOps*.javagenerated files that no longer exist).BerlinMODCorpus.synthetic()corpus — the canonicalberlinmod_instants.csvis the only data source.MeosWiringsDemoTopologyout ofsrc/main(it used the test-scopedTopologyTestDriver) — same fix as the scaffold'sBerlinMODFullMatrixTest.Verification
mvn test→ 11 tests, 0 failures (full matrix + 7 MEOS smokes + set-set join), built against MEOS 1.4 from pin588768d7(MobilityDB #1148 set-set join). MEOS smokes run withreuseForks=falsefor a clean native lifecycle.Depends on MobilityDB #1148 (set-set spatial join) for the
*_tgeoarr_tgeoarrsymbols, pinned via the bundled libmeos.