3 रिपॉजिटरी
Environments for executing analytical transformations and automated tasks on data streams.
Distinguishing note: Focuses on functional execution against streams rather than general-purpose batch processing.
Explore 3 awesome GitHub repositories matching data & databases · Dataflow Engines. Refine with filters or upvote what's useful.
InfluxDB is a specialized time series database platform engineered for the high-speed ingestion, compression, and retrieval of timestamped data at scale. It functions as a distributed metrics platform, providing the infrastructure necessary to organize and analyze massive volumes of time-stamped information to identify trends, patterns, and anomalies within complex data streams. The platform distinguishes itself through a functional dataflow engine that utilizes a specialized programming language for complex analytical transformations and automated tasks. This architecture is supported by a p
Executes complex analytical transformations and automated tasks directly against stored data streams.
Rete is a framework for building interactive, node-based visual interfaces and dataflow programming environments. It provides a core engine that processes directed graphs, allowing developers to define modular logic where nodes represent operations and connections represent the flow of data or control. By decoupling the graph logic from the user interface, the framework enables the creation of custom visual editors that can be integrated into various frontend component libraries. The project distinguishes itself through a highly extensible, signal-driven architecture that supports complex req
Offers a hybrid execution model that combines data-driven propagation with explicit control-flow triggers for complex procedural logic.
Noria एक डायनामिक डेटाफ़्लो इंजन और मैटेरियलाइज्ड व्यू डेटाबेस है जो महंगे रीड ऑपरेशंस को तेज़ की-आधारित लुकअप में बदल देता है। यह एक स्टेटफ़ुल सिस्टम के रूप में कार्य करता है जो अंतर्निहित रिलेशनल बेस टेबल के बदलने पर आश्रित व्यू को क्रमिक रूप से अपडेट करता है। सिस्टम एक MySQL प्रोटोकॉल एमुलेटर के रूप में कार्य कर सकता है, जो बाइनरी प्रोटोकॉल की नकल करता है ताकि एप्लिकेशन क्लाइंट कोड को बदले बिना प्रीकंप्यूटेड डेटा प्राप्त कर सकें। इसे Rust एम्बेडेड डेटाबेस के रूप में भी इस्तेमाल किया जा सकता है, जो बाहरी समन्वय के बिना डेटाफ़्लो ऑपरेशंस करने के लिए नेटिव बाइंडिंग के माध्यम से सर्वर को सीधे प्रोग्राम में एकीकृत करता है। यह प्रोजेक्ट वितरित डेटाफ़्लो समन्वय को कवर करता है, जिसमें हार्टबीट्स के माध्यम से वर्कर नोड हेल्थ ट्रैकिंग शामिल है। यह रिलेशनल टेबल प्रबंधन, इंक्रीमेंटल व्यू सिंक्रोनाइज़ेशन और डेटा फ़्लो ग्राफ़ प्रबंधन के लिए उपकरण प्रदान करता है। ऑब्जर्वेबिलिटी का समर्थन डोमेन सांख्यिकी संग्रह, प्रदर्शन बेंचमार्किंग और प्रीकंप्यूटेड परिणामों को ब्राउज़ करने के लिए एक वेब डेटा इंस्पेक्टर के माध्यम से किया जाता है।
Implements a stateful dataflow engine that incrementally updates materialized views based on relational table changes.