A Scala API for Apache Beam and Google Cloud Dataflow.
Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.
Scalable, Portable and Distributed Gradient Boosting (GBDT, GBRT or GBM) Library, for Python, R, Java, Scala, C and more. Runs on single machine, Hadoop, Spark, Dask, Flink and DataFlow
A reactive notebook for Python — run reproducible experiments, query with SQL, execute as a script, deploy as an app, and version with git. Stored as pure Python. All in a modern, AI-native editor.
JavaScript framework for visual programming
[SIGMOD'27] Easy Data Preparation with latest LLMs-based Operators and Pipelines.
Next Generation Visual Programming System
DORA (Dataflow-Oriented Robotic Architecture) is middleware designed to streamline and simplify the creation of AI-based robotic applications. It offers low latency, composable, and distributed dataflow capabilities. Applications are modeled as directed graphs, also referred to as pipelines.
A modular implementation of timely dataflow in Rust
Open-source code analysis platform for C/C++/Java/Binary/Javascript/Python/Kotlin based on code property graphs. Discord https://discord.gg/vv4MH284Hc
A workflow language for data-driven computational pipelines
🔥🔥 AllData可定义数据中台,以数据平台为底座,以数据中台为桥梁,以机器学习平台为工厂,以大模型应用为上游产品,提供全链路数字化解决方案。产品正式演示体验、社群咨询、商务采购:https://docs.qq.com/doc/DVHlkSEtvVXVCdEFo
Common solutions and tools developed by Google Cloud's Professional Services team. This repository and its contents are not an officially supported Google product.
An implementation of differential dataflow using timely dataflow on Rust.
Code security scanning tool (SAST) to discover, filter and prioritize security and privacy risks.
Apache Hamilton helps data scientists and engineers define testable, modular, self-documenting dataflows, that encode lineage/tracing and metadata. Runs and scales everywhere python does.
Python Stream Processing
ZEn NOde system - a simulation & rendering engine in nodes
Cloud Dataflow Google-provided templates for solving in-Cloud data tasks
A reactive Python kernel for Jupyter notebooks.
A Pythonic framework for threat modeling
Dataflow compiler for QNN inference on FPGAs
High performance, streaming and concurrent functional programming in Haskell
T.J. Watson Libraries for Analysis, with front ends for Java, Android, and JavaScript, and many common static program analyses.
Workflows and interfaces for neuroimaging packages
A new version of Soot with a completely overhauled architecture
数据流引擎是一款面向数据集成、数据同步、数据交换、数据共享、任务配置、任务调度的底层数据驱动引擎。数据流引擎采用管执分离、多流层、插件库等体系应对大规模数据任务、数据高频上报、数据高频采集、异构数据兼容的实际数据问题。
🔥🔥🔥可视化拖拽式大数据集成平台、大数据平台、大数据,包含数据流、数据源、数据对齐、查询模板、智能问数、AI集成、完善的监控等。像画流程图一样且无代码方式同步、清洗数据。
Swift + Redux + (SwiftConcurrency | Combine | RxSwift | ReactiveSwift | ReactiveConcurrency) -> SwiftRex
An open-source execution engine for AI-SQL and LLM-powered dataflow