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

6540
0.3GB
JSON
CATL
MOBIUSI INC

Updated:2026-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.

Dataset Insights

Sample Examples

{}

Technical Specifications

Field	Type	Description
file_name	string	File name
join_outputs	array	Final or incremental records produced by temporal stream join computations.
event_streams	array	Raw event sequences from different sources, including event time, arrival time, join keys, and event payloads.
match_relations	array	Cross-stream event matches derived from join keys, join time windows, and watermark rules.
state_evolution	array	Records of watermark progression, state creation, retention, and expiration during stream processing.
late_event_impact	object	A summary of how late events affect acceptance, dropping, retrospective matching, and join outputs.
simulation_config	object	Time ranges, join windows, lateness policies, state-retention settings, and watermark configurations used to generate temporal stream join samples.
watermark_summary	object	A summary of watermark quality and delay inferred from event times and arrival order.

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

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

Verified for Enterprise Use

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},
  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

Scene

Domain

Modality

Task