Skip to content

docs(profile): describe stream-layers tier as a solid peer (figure + text + in-flight PRs)#10

Open
estebanzimanyi wants to merge 4 commits into
MobilityDB:mainfrom
estebanzimanyi:docs/stream-readiness-findings
Open

docs(profile): describe stream-layers tier as a solid peer (figure + text + in-flight PRs)#10
estebanzimanyi wants to merge 4 commits into
MobilityDB:mainfrom
estebanzimanyi:docs/stream-readiness-findings

Conversation

@estebanzimanyi
Copy link
Copy Markdown
Member

@estebanzimanyi estebanzimanyi commented May 20, 2026

Describes the present-state facts about the planned stream-layers tier in the profile README:

  • Parity contract matches the SQL-layer one: the same BerlinMOD reference queries run across all three planned platforms in three streaming forms — continuous (always-on), windowed (tumbling / sliding / session), and snapshot (query at time T, ≡ the batch result at the same scale factor). The snapshot form is anchored to the batch BerlinMOD outputs in MobilityDB-BerlinMOD; the same generator and scale-factor axis as the batch side are reused.
  • Bindings split: the Flink and Kafka platforms use JMEOS; MobilityNebula calls MEOS directly through its C ABI.
  • The MobilityNebula (EDBT 2026) paper is the published reference architecture; the SNCB railway data is the application demonstration of the methodology, not the parity contract itself.

The figure stays dashed and ghosted — the band only becomes solid when the cross-platform streaming parity is real, in line with the rest of the profile (MobilitySpark is depicted as a solid peer SQL box because it is real).

This is a text-only change to profile/README.md; no figure or table-of-repositories edits.

… longer dashed

State the present-state facts about the stream-layers tier:

- The same edge-to-cloud model runs on the streaming side, each tool in
  its canonical role (MobilityNebula edge / MobilityKafka transport /
  MobilityFlink cloud).
- The published reference architecture is the MobilityNebula EDBT 2026
  paper; the SNCB railway data is the application demonstration.
- The parity contract matches the SQL-layer one — the same BerlinMOD
  reference queries across all three platforms in three streaming forms
  (continuous / windowed / snapshot), anchored to MobilityDB-BerlinMOD
  on the snapshot form.
- Bindings split is JMEOS for the JVM platforms (Flink, Kafka);
  MobilityNebula calls MEOS directly through its C ABI.
- The streaming-form scaffolds are tracked in three open PRs against
  the planned-tier repositories — MobilityFlink#3, MobilityKafka#1 and
  MobilityNebula#15 — each implementing the BerlinMOD-Q × 3-form cells
  in the runtime's native operator surface.

Figure update: the Stream-layers box is now a solid pastel-sky peer
(fill #e0f2fe, stroke #7dd3fc) matching the SQL/HTTP/Bindings boxes in
shape, with a connector arrow to the MEOS core. The Stream-layers
legend entry switches from a dashed swatch to the solid sky swatch.
The 'PLANNED (roadmap)' framing is removed from the figure desc and
section comments throughout.
@estebanzimanyi estebanzimanyi force-pushed the docs/stream-readiness-findings branch from dbb22e5 to 63cea0b Compare May 21, 2026 06:42
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant