Alternatives and similar repositories for stateful-streaming-examples:

Users that are interested in stateful-streaming-examples are comparing it to the libraries listed below

• delta-incubator / deltatorch
  ☆54Updated last year
• fugue-project / tutorials
  Tutorials for Fugue - A unified interface for distributed computing. Fugue executes SQL, Python, and Pandas code on Spark and Dask withou…
  ☆112Updated 10 months ago
• godatadriven / pydantic-avro
  This library can convert a pydantic class to a avro schema or generate python code from a avro schema.
  ☆68Updated 2 weeks ago
• delta-incubator / deltaray
  Delta reader for the Ray open-source toolkit for building ML applications
  ☆45Updated last year
• Nike-Inc / brickflow
  Pythonic Programming Framework to orchestrate jobs in Databricks Workflow
  ☆199Updated last week
• ibis-project / ibis-ml
  IbisML is a library for building scalable ML pipelines using Ibis.
  ☆100Updated last month
• BauplanLabs / quack-reduce
  A playground for running duckdb as a stateless query engine over a data lake
  ☆184Updated last year
• sfu-db / lineagex
  ☆67Updated last week
• rh-marketingops / fluvii
  A kafka streams client library built on confluent-kafka-python
  ☆67Updated last year
• mitchelllisle / sparkdantic
  ✨ A Pydantic to PySpark schema library
  ☆69Updated this week
• dremio-hub / arrow-flight-client-examples
  ☆68Updated last month
• outerbounds / terraform-aws-metaflow
  Deploy production-grade Metaflow cloud infrastructure on AWS
  ☆61Updated last month
• anna-geller / prefect-deployment-patterns
  Code examples showing flow deployment to various types of infrastructure
  ☆104Updated 2 years ago
• danielgafni / dagster-ray
  Ray integration for Dagster
  ☆36Updated this week
• getindata / kedro-kubeflow
  Kedro Plugin to support running workflows on Kubeflow Pipelines
  ☆53Updated 5 months ago
• jeppe742 / DeltaLakeReader
  Read Delta tables without any Spark
  ☆47Updated 11 months ago
• getindata / kedro-vertexai
  Kedro Plugin to support running workflows on GCP Vertex AI Pipelines
  ☆35Updated 2 weeks ago
• aporia-ai / inferencedb
  🚀 Stream inferences of real-time ML models in production to any data lake (Experimental)
  ☆79Updated 2 years ago
• njanakiev / trino-minio-docker
  Minimal example to run Trino, Minio, and Hive standalone metastore on docker
  ☆49Updated 2 years ago
• rajagurunath / lakehouse-sharing
  A Table format agnostic data sharing framework
  ☆38Updated last year
• davidmirror-ops / flyte-the-hard-way
  Prepare requirements and deploy Flyte using Helm
  ☆62Updated last month
• coiled / dask-snowflake
  Dask integration for Snowflake
  ☆30Updated 3 months ago
• apache / datafusion-python
  Apache DataFusion Python Bindings
  ☆414Updated this week
• anyscale / airflow-provider-ray
  Ray provider for Apache Airflow
  ☆47Updated last year
• jacopotagliabue / paas-data-ingestion
  Ingesting data with Pulumi, AWS lambdas and Snowflake in a scalable, fully replayable manner
  ☆71Updated 3 years ago
• benchsci / tinsel
  PySpark schema generator
  ☆41Updated last year
• BauplanLabs / no-jvm-wap-with-iceberg
  A write-audit-publish implementation on a data lake without the JVM
  ☆46Updated 6 months ago
• ray-project / deltacat
  A portable Pythonic Data Lakehouse powered by Ray that brings exabyte-level scalability and fast, ACID-compliant, change-data-capture to …
  ☆192Updated this week
• canimus / cuallee
  Possibly the fastest DataFrame-agnostic quality check library in town.
  ☆181Updated last week