Batch-Stream Replay Fixtures

Parquet, SQLite, JSONL, NDJSON, and MessagePack fixtures for comparing warehouse-style batch inputs with replayable stream and CDC workflows.

Why This Workflow Matters

  • Bridges batch files, embedded relational state, and append-only streams in one replay-oriented workflow.
  • Useful when migrating from batch ingestion to streaming pipelines or reconciling replay behavior across both models.
  • Anchored to a pack that gives batch-vs-stream suites one-click fixture setup.

Recommended Packs

Batch-Stream Replay Fixture Pack

Bundle of real Parquet, SQLite, JSONL, NDJSON, and MessagePack fixtures for comparing batch ingestion with replayable stream workflows.

batch_stream_replay_fixture_pack.zip · 2.9 KB

ETL Validation Fixture Pack

Bundle of real Parquet, Avro, SQLite, NDJSON, and CSV fixtures for ETL staging, warehouse loads, and ingestion-pipeline validation.

etl_validation_fixture_pack.zip · 4.6 KB

Cache Serialization Fixture Pack

Bundle of real MessagePack, SESSION, JWT, JSON, and SQLite fixtures for cache serialization, replay, and embedded-state debugging.

cache_serialization_fixture_pack.zip · 2.8 KB

Fixture Matrices

Parquet Ingestion Fixture Matrix

Choose Parquet fixtures for columnar ingestion, warehouse imports, nested-column handling, and batch-load validation.

SQLite Local Database Fixture Matrix

Choose SQLite fixtures for embedded database replay, schema changes, staging imports, and local-analysis workflows.

JSONL Event Stream Fixture Matrix

Choose JSONL fixtures for event streams, CDC feeds, and schema-drift validation in append-only pipelines.

NDJSON Webhook Fixture Matrix

Choose NDJSON fixtures for delivery streams, API activity feeds, and malformed line-delimited event debugging.

MessagePack Cache Fixture Matrix

Use MessagePack fixtures for cache payloads, compact event batches, and binary serialization compatibility checks.

Suggested Fixtures

Filename Format Size Actions
parquet_alltypes_plain_sample.parquet PARQUET 1.8 KB
sqlite_local_replay_sample.sqlite SQLITE 16.0 KB
jsonl_schema_drift_stream_sample.jsonl JSONL 383 B
jsonl_cdc_changefeed_sample.jsonl JSONL 363 B
ndjson_api_activity_stream_sample.ndjson NDJSON 313 B
msgpack_cache_payload_sample.msgpack MSGPACK 130 B