feat(berlinmod): route the streaming parity matrix through MEOS via JMEOS 1.4#30
Open
estebanzimanyi wants to merge 2 commits into
Open
Conversation
This was referenced Jun 11, 2026
Closed
Closed
Closed
Closed
Closed
Closed
Closed
…MEOS 1.4 The BerlinMOD-9 × 3-form Flink DataStream functions route their spatial predicates and distances through MEOS (libmeos via the JMEOS 1.4 bridge) instead of pure-Java fallbacks: edwithin / eintersects / geog_distance and the set-set join family. Adds the MEOS DataStream tier wirings (stateless / bounded-state / windowed / cross-stream) with their demo jobs, per-family MEOS facade smoke tests (cbuffer / npoint / pose), a set-set spatial-join verification test, the canonical BerlinMOD corpus loader and the BerlinMODParity driver — both run on the canonical berlinmod_instants.csv only (the invented synthetic corpus is removed). Drops the dead family-flag Maven profiles (they excluded meos/MeosOps*.java generated files that no longer exist), untracks the stale committed target/ build artifacts (now gitignored), and runs the MEOS smoke tests in their own JVM fork (reuseForks=false) for a clean native lifecycle.
estebanzimanyi
force-pushed
the
consolidate/flink-meos-integration
branch
from
6d06a5f to
db2e51b
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, and the org.mobilitydb.meos MeosOps* facade is regenerated against it. Migrate the aisdata processors off the removed functions.functions facade onto GeneratedFunctions (meos_initialize / meos_initialize_timezone / meos_finalize); the berlinmod package already used GeneratedFunctions + the MeosOps facade. Verified: flink-processor compiles and its test suite is green (10 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 — Flink MEOS integration (scaffold #3 is already merged to main).
Collapses the former 18-deep MEOS stack (old #4–#21, #25) into one topical commit on top of main: routes the BerlinMOD-9 × 3-form DataStream functions through MEOS (libmeos via the JMEOS 1.4 bridge) and adds the MEOS tier wirings + demo jobs + per-family facade smoke tests + canonical corpus loader + BerlinMODParity driver.
Irregularities removed vs. the old stack
jar/JMEOS.jar); the old stack added ~30k generated lines then deleted them.meos/MeosOps*.javafiles that no longer exist).synthetic()corpus —BerlinMODParityruns on the canonicalberlinmod_instants.csvonly.target/build artifacts (now gitignored).Verification
mvn test→ 10 tests, 0 failures, built against MEOS 1.4 from pin588768d7(MobilityDB #1148 set-set join). MEOS smokes run withreuseForks=false.