Temporal Stream Join State Reasoning Simulation Dataset

#Stream Processing #Temporal Join Matching #Event-Time Reasoning #State Evolution Analysis #Late-Event Handling #Stream Processing Engine Validation #Real-Time Pipeline Testing #Event-Time Analysis #Join State Management Evaluation
Records
6540
Size
0.3GB
Format
JSON
Provider
MOBIUSI INCMOBIUSI INC
Updated
v1.02026-11-04
AI Analysis & Value Prop

This dataset simulates temporal joins across multiple event streams under varied time ranges, join windows, lateness policies, state-retention periods, and watermark configurations. It includes event sequences, cross-stream match relations, join-state evolution, late-event impacts, and final or incremental outputs. The data supports analysis of how event time and arrival order affect join results and state management, as well as stream-processing engine validation, algorithm evaluation, and reasoning model training.

Overview

Dataset Insights

Preview

Sample Examples

sample.json
{}

Schema

Technical Specifications

file_namestringFile name
join_outputsarrayFinal or incremental records produced by temporal stream join computations.
event_streamsarrayRaw event sequences from different sources, including event time, arrival time, join keys, and event payloads.
match_relationsarrayCross-stream event matches derived from join keys, join time windows, and watermark rules.
state_evolutionarrayRecords of watermark progression, state creation, retention, and expiration during stream processing.
late_event_impactobjectA summary of how late events affect acceptance, dropping, retrospective matching, and join outputs.
simulation_configobjectTime ranges, join windows, lateness policies, state-retention settings, and watermark configurations used to generate temporal stream join samples.
watermark_summaryobjectA summary of watermark quality and delay inferred from event times and arrival order.

Trust

Compliance Statement

Authorization Type

Proprietary - Commercial AI Training License (No Redistribution)

Commercial Use

Requires exclusive subscription or authorization contract (monthly or per-invocation charging)

Privacy and Anonymization

No PII, no real company names, simulated scenarios follow industry standards

Compliance System

Compliant with China's Data Security Law / EU GDPR / supports enterprise data access logs

FAQ

Frequently Asked Questions

What does the dataset contain?
It includes simulation configurations, multi-source event streams, join match relations, join-state evolution, late-event impacts, join outputs, and watermark reasoning summaries. These records support tracing the process from input events to join results.
Can the data be used to evaluate late-event handling?
Yes. Samples cover different lateness policies and watermark conditions, recording how late events affect acceptance, dropping, retrospective matching, and join outputs. This supports analysis of late-event processing logic.
Is this data from a production environment?
This is generated data for simulation learning, not a record of measurements from a specific production environment. Before making deployment decisions, validate findings against the target engine, workload, and real event distributions.
How can I access the data, and what are the licensing terms?
Check the dataset product page for available formats, samples, delivery options, and licensing terms. Download permissions and permitted uses are subject to the terms published on that page.

Can't find the data you need?

Post a request and let data providers reach out to you.

Get this Dataset

High-quality data, ready for your next AI breakthrough.

Cite this Work

@dataset{Mobiusi2026,
  title={Temporal Stream Join State Reasoning Simulation Dataset},
  author={MOBIUSI INC},
  year={2026},
  url={https://www.mobiusi.com/datasets/bde09f5c6d722bc6c524adfcbade54a9?dataset_scene_id=19},
  urldate={2026-10-28},
  keywords={temporal stream join dataset,stream processing simulation,multi-stream join reasoning,watermark analysis,late event handling,join state evolution,event-time joins,stream engine testing},
  version={1.0}
}

Using this in research? Please cite us.

placeholder
placeholder
placeholder
placeholder
placeholder
placeholder
placeholder

Popular Dataset Searches