Softlandia-Ltd / stateful-streaming-examplesLinks
Stateful streaming computations implemented with many technologies
☆32Updated last year
Alternatives and similar repositories for stateful-streaming-examples
Users that are interested in stateful-streaming-examples are comparing it to the libraries listed below
Sorting:
- Apache DataFusion Python Bindings☆554Updated this week
- Possibly the fastest DataFrame-agnostic quality check library in town.☆234Updated 3 months ago
- A high-performance data streaming system using DuckDB and Apache Arrow Flight.☆95Updated 11 months ago
- Delta reader for the Ray open-source toolkit for building ML applications☆45Updated 2 years ago
- A playground for running duckdb as a stateless query engine over a data lake☆218Updated 2 years ago
- Tutorials for Fugue - A unified interface for distributed computing. Fugue executes SQL, Python, and Pandas code on Spark and Dask withou…☆114Updated 2 months ago
- A data modelling layer built on top of polars and pydantic☆197Updated 2 years ago
- fsspec-compatible Azure Blob and Data Lake Storage (Gen2) access☆204Updated this week
- Turning PySpark Into a Universal DataFrame API☆481Updated this week
- An fsspec implementation for the lakeFS project☆61Updated 2 weeks ago
- Stream Arrow data into Postgres☆278Updated last week
- ✨ A Pydantic to PySpark schema library☆118Updated last week
- IbisML is a library for building scalable ML pipelines using Ibis.☆120Updated 6 months ago
- Ray integration for Dagster☆61Updated last week
- SQLAlchemy driver for DuckDB☆482Updated this week
- Distributed SQL Engine in Python using Dask☆409Updated last year
- ☆176Updated 8 months ago
- Write your dbt models using Ibis☆74Updated 10 months ago
- Work with your web service, database, and streaming schemas in a single format.☆350Updated last month
- 🏃♀️ Minimalist SQL orchestrator☆302Updated this week
- Pythonic Programming Framework to orchestrate jobs in Databricks Workflow☆224Updated last month
- A compute manifest and composable tools for ML, built on Ibis, DataFusion, and Arrow Flight.☆481Updated this week
- PyAirbyte brings the power of Airbyte to every Python developer.☆315Updated this week
- Pocket data flows orchestrated using Prefect☆48Updated 2 weeks ago
- ☆70Updated last year
- ☆81Updated 11 months ago
- A portable Multimodal Lakehouse powered by Ray that brings exabyte-level scalability and fast, ACID-compliant, change-data-capture to you…☆267Updated last week
- Anomstack - Painless open source anomaly detection for your metrics 📈📉🚀☆107Updated this week
- The Modern Data Stack in a Python package☆49Updated 2 years ago
- This library can convert a pydantic class to a avro schema or generate python code from a avro schema.☆82Updated this week