☆81Nov 10, 2023Updated 2 years ago
Alternatives and similar repositories for beam-samples
Users that are interested in beam-samples are comparing it to the libraries listed below
Sorting:
- An example Apache Beam project.☆111May 26, 2017Updated 8 years ago
- Apache Beam Site☆30Jan 22, 2026Updated last month
- ☆22Dec 30, 2018Updated 7 years ago
- Get started with Apache Beam and Flink☆43Oct 28, 2016Updated 9 years ago
- Uses Cloud Build to deploy a scalable batch ingestion pipeline consisting of GCS, Cloud Functions, Dataflow and BigQuery☆22Dec 7, 2022Updated 3 years ago
- Apache Beam Example 中国开源社区☆21Jul 1, 2022Updated 3 years ago
- Example that shows use of the Prediction API☆10Apr 12, 2018Updated 7 years ago
- Apache Ignite Website☆13Feb 20, 2026Updated last week
- Distributed Messaging Framework based on Netty, Apache Ignite, gRPC☆13Dec 17, 2018Updated 7 years ago
- Repository for building CDAP and additional external projects☆16Updated this week
- ☆13May 13, 2021Updated 4 years ago
- A curated list of awesome resources for Apache Beam☆145Nov 11, 2022Updated 3 years ago
- Kafka to Avro Writer based on Apache Beam. It's a generic solution that reads data from multiple kafka topics and stores it on in cloud s…☆25Apr 7, 2021Updated 4 years ago
- Repository for streaming and batch samples of timeseries data☆26Feb 23, 2021Updated 5 years ago
- Showing the relationship between ImageNet ID and labels and pytorch pre-trained model output ID and labels☆10Oct 11, 2020Updated 5 years ago
- Simple machine learning in Python/Tensorflow with model saving☆14Jul 27, 2017Updated 8 years ago
- java gui to browse cassandra☆22Aug 2, 2012Updated 13 years ago
- Spring Boot microservice to demo integration with Dapr for event-driven, Pact for consumer-driven contract testing, Liquibase, etc. Also …☆14Updated this week
- Tasks API for Stateful Functions on Flink☆13Feb 14, 2026Updated 2 weeks ago
- Apache Nifi custom processor - web scraping powered by selenium☆14Sep 20, 2018Updated 7 years ago
- Lab project to showcase Flink's performance differences between using a SQL query and implementing the same logic via the DataStream API☆14Apr 15, 2020Updated 5 years ago
- Python Streaming Pipelines with Beam on Flink - Demo☆14Dec 8, 2022Updated 3 years ago
- Cloud Dataflow Google-provided templates for solving in-Cloud data tasks☆1,273Updated this week
- Kafka, Spark Streaming, Kudu integration examples☆17Dec 22, 2017Updated 8 years ago
- Scalable CDC Pattern Implemented using PySpark☆18Oct 8, 2025Updated 4 months ago
- Starburst Enterprise Distribution of Presto☆45Aug 31, 2021Updated 4 years ago
- a set of benchmarks to test Storm performance☆15Jul 23, 2016Updated 9 years ago
- This example demonstrates a Contacts management application for managing a user's contacts. Its purpose is to serve as the Reference Imp…☆19Apr 17, 2023Updated 2 years ago
- ☆175Sep 5, 2023Updated 2 years ago
- Flink stream filtering examples☆19Jun 23, 2016Updated 9 years ago
- ☆20Sep 26, 2017Updated 8 years ago
- .NET driver for Apache Phoenix and Phoenix Query Server☆22Mar 28, 2023Updated 2 years ago
- A Terraform template for provisioning Apache Airflow workflows on AWS ECS Fargate☆14May 28, 2020Updated 5 years ago
- Apache Flink™ training material website☆78Apr 22, 2020Updated 5 years ago
- ☆20Aug 20, 2019Updated 6 years ago
- Deterministic transactional database layer on top of a stream processing engine☆27Oct 27, 2019Updated 6 years ago
- A Scala API for Apache Beam and Google Cloud Dataflow.☆2,615Feb 12, 2026Updated 2 weeks ago
- NEW: see http://www.hops.io/. OLD: This work aims to re-engineer the Hadoop Distributed File System (HDFS) so that it can be 1) highly av…☆26Jan 2, 2012Updated 14 years ago
- Cascading on Apache Flink®☆54Feb 5, 2024Updated 2 years ago