Powered by OpenAIRE graph
Found an issue? Give us feedback
image/svg+xml art designer at PLoS, modified by Wikipedia users Nina, Beao, JakobVoss, and AnonMoos Open Access logo, converted into svg, designed by PLoS. This version with transparent background. http://commons.wikimedia.org/wiki/File:Open_Access_logo_PLoS_white.svg art designer at PLoS, modified by Wikipedia users Nina, Beao, JakobVoss, and AnonMoos http://www.plos.org/ ZENODOarrow_drop_down
image/svg+xml art designer at PLoS, modified by Wikipedia users Nina, Beao, JakobVoss, and AnonMoos Open Access logo, converted into svg, designed by PLoS. This version with transparent background. http://commons.wikimedia.org/wiki/File:Open_Access_logo_PLoS_white.svg art designer at PLoS, modified by Wikipedia users Nina, Beao, JakobVoss, and AnonMoos http://www.plos.org/
ZENODO
Article . 2023
License: CC BY
Data sources: ZENODO
ZENODO
Article . 2023
License: CC BY
Data sources: Datacite
ZENODO
Article . 2023
License: CC BY
Data sources: Datacite
versions View all 2 versions
addClaim

AutoSchema: A Self-Learning Framework for Detecting and Adapting to Schema Drift in Real-Time Data Streams

Authors: Rajani Kumari Vaddepalli;

AutoSchema: A Self-Learning Framework for Detecting and Adapting to Schema Drift in Real-Time Data Streams

Abstract

Streaming pipelines need to be able to handle datasets that change quickly and have schemas that change as well in today's fast-paced, data-driven world. When schema changes happen that aren't expected, traditional schema management methods that rely on static rules or manual updates typically don't work, which might break pipelines or corrupt data. To solve this problem, we provide AutoSchema, a self-supervised learning framework that can find and fix schema drift in real-time data streams without any help from people. AutoSchema employs a two-part neural approach: A drift detection system that finds schema problems via contrastive learning. This cuts down on false alarms by a lot compared to older rule-based systems. A dynamic schema adapter that uses graph-based metadata learning to rebuild and check new schema mappings as they happen, preventing pipeline problems. We used AutoSchema on a variety of streaming datasets, such as IoT sensors, financial transactions, and log analytics, and found that it was 98.3% accurate in finding schema drift (22% better than rule-based methods). Adaptation in less than a second, which keeps the data flowing. 70% faster recovery than the best tools for schema evolution. Our results show that AutoSchema makes pipelines more resilient to schema changes while keeping costs low, making it perfect for big applications. This study fills in a big gap in autonomous data management by giving businesses a dependable way to handle dynamic streaming settings.

Keywords

Self-supervised learning, autonomous pipelines, real-time data pipeline, schema drift, IoT data handling

  • BIP!
    Impact byBIP!
    selected citations
    These citations are derived from selected sources.
    This is an alternative to the "Influence" indicator, which also reflects the overall/total impact of an article in the research community at large, based on the underlying citation network (diachronically).
    0
    popularity
    This indicator reflects the "current" impact/attention (the "hype") of an article in the research community at large, based on the underlying citation network.
    Average
    influence
    This indicator reflects the overall/total impact of an article in the research community at large, based on the underlying citation network (diachronically).
    Average
    impulse
    This indicator reflects the initial momentum of an article directly after its publication, based on the underlying citation network.
    Average
Powered by OpenAIRE graph
Found an issue? Give us feedback
selected citations
These citations are derived from selected sources.
This is an alternative to the "Influence" indicator, which also reflects the overall/total impact of an article in the research community at large, based on the underlying citation network (diachronically).
BIP!Citations provided by BIP!
popularity
This indicator reflects the "current" impact/attention (the "hype") of an article in the research community at large, based on the underlying citation network.
BIP!Popularity provided by BIP!
influence
This indicator reflects the overall/total impact of an article in the research community at large, based on the underlying citation network (diachronically).
BIP!Influence provided by BIP!
impulse
This indicator reflects the initial momentum of an article directly after its publication, based on the underlying citation network.
BIP!Impulse provided by BIP!
0
Average
Average
Average
Green