Adaptive Statistical Data Quality Detection for Real-Time Streaming Pipelines: Beyond Rule-Based Validation

This paper presents an adaptive statistical framework for real-time data quality detection in streaming pipelines, replacing hardcoded rule-based validation with distribution-aware monitoring. The framework combines Kolmogorov-Smirnov testing, Population Stability Index scoring, and Wasserstein distance measurement with an empirically validated recalibration heuristic. Validated on 2,136,000 synthetic records across 90 days and 1,424 micro-batches. Results demonstrate 98.4% false positive reduction versus rule-based baseline with 0 incorrect recalibrations over the full simulation period.

Authors

Publication Details

Journal
Zenodo (CERN European Organization for Nuclear Research)
Published
2026-03-12
DOI
https://doi.org/10.5281/zenodo.19129208
Primary Topic
Data Stream Mining Techniques
Type
article
Field-Weighted Citation Impact
0.00
Controls
|||
ALL TIME
JAN
FEB
MAR
APR
MAY
JUN
JUL
AUG
SEP
OCT
article

Adaptive Statistical Data Quality Detection for Real-Time Streaming Pipelines: Beyond Rule-Based Validation

Thanigaivendhan Thiyagarajan
Zenodo (CERN European Organization for Nuclear Research)
Data Stream Mining Techniques
article

Adaptive Statistical Data Quality Detection for Real-Time Streaming Pipelines: Beyond Rule-Based Validation

Thanigaivendhan Thiyagarajan
article en

Abstract

This paper presents an adaptive statistical framework for real-time data quality detection in streaming pipelines, replacing hardcoded rule-based validation with distribution-aware monitoring. The framework combines Kolmogorov-Smirnov testing, Population Stability Index scoring, and Wasserstein distance measurement with an empirically validated recalibration heuristic. Validated on 2,136,000 synthetic records across 90 days and 1,424 micro-batches. Results demonstrate 98.4% false positive reduction versus rule-based baseline with 0 incorrect recalibrations over the full simulation period.

Zenodo (CERN European Organization for Nuclear Research)
Openalex Percentile: Top 17%
Data Stream Mining Techniques
AI Navigator

Ask Laika to Summarize, Analyze, and Connect papers live on the map.

Summarize Papers & Methodologies

Extract key findings, datasets, and comparative methods across publications.

Benchmark Rankings & Visual Analytics

Rank top research institutions, authors, funders, topics, and journals by Field-Weighted Citation Impact (FWCI) and paper volume with instant charts.

Connect Distant Disciplines

Bridge topological clusters on the map to find hidden collaborative intersections.