Google Dataflow Runner for Apache Flink™ (deprecated; please use the up-to-date Beam Runner)
☆88Jul 7, 2016Updated 9 years ago
Alternatives and similar repositories for flink-dataflow
Users that are interested in flink-dataflow are comparing it to the libraries listed below
Sorting:
- Cascading on Apache Flink®☆54Feb 5, 2024Updated 2 years ago
- A streaming key-value store implementation using native Flink Streaming operators☆23Oct 10, 2015Updated 10 years ago
- Google Cloud Dataflow provides a simple, powerful model for building both batch and streaming parallel data processing pipelines.☆851Nov 25, 2020Updated 5 years ago
- Queryable Window Example☆10Mar 9, 2016Updated 9 years ago
- Spooker is a dynamic framework for processing high volume data streams via processing pipelines☆30Feb 1, 2016Updated 10 years ago
- An integration framework that allows you to run and manage CrateDB via Apache Mesos.☆23Jan 30, 2019Updated 7 years ago
- Framework for Apache Flink unit tests☆210Apr 28, 2019Updated 6 years ago
- A compiler for Pig Latin to Spark and Flink.☆23Nov 21, 2019Updated 6 years ago
- ☆240Aug 9, 2021Updated 4 years ago
- ☆70Jul 18, 2017Updated 8 years ago
- Mirror of Apache Samoa (Incubating)☆251Apr 16, 2023Updated 2 years ago
- A small framework to define long running (persistent)processes.☆29Dec 10, 2016Updated 9 years ago
- Starter project for building MemSQL Streamliner Pipelines☆32Apr 18, 2017Updated 8 years ago
- Apache Flink cluster deployment in Docker containers using Docker-Compose☆17Mar 24, 2015Updated 10 years ago
- Utilities for building distributed systems on top of mesos☆23Aug 25, 2018Updated 7 years ago
- ☆23Jun 11, 2015Updated 10 years ago
- Apache Flink example CEP program to monitor data center temperatures☆129Oct 28, 2018Updated 7 years ago
- Distributed Temporal Graph Analytics with Apache Flink☆251Jan 11, 2026Updated last month
- Discover Flink clusters on Hadoop YARN for Prometheus☆23Aug 5, 2020Updated 5 years ago
- Using the Parquet file format (with Avro) to process data with Apache Flink☆14Aug 17, 2015Updated 10 years ago
- Mixin classes and traits dynamically☆10Sep 4, 2017Updated 8 years ago
- Fast, simple Free Monads using ScalaMeta macro annotations. Port of Freasy-Monad.☆14Oct 16, 2017Updated 8 years ago
- ☆13Oct 4, 2022Updated 3 years ago
- A Kafka-Connect Sink for S3 with no Hadoop dependencies.☆57Mar 19, 2023Updated 2 years ago
- An mtl-style typeclass and transformer for persistent☆11Sep 18, 2018Updated 7 years ago
- What happens on the wire when Hadoop RPC call is issued?☆13Jul 1, 2022Updated 3 years ago
- SRV record support for legacy systems via LD_PRELOAD getaddrinfo/connect hooks☆14Aug 20, 2015Updated 10 years ago
- ***Warning*** Old Apache Flink Graph API: This repository is not in use anymore.☆15Jan 18, 2016Updated 10 years ago
- An experimental Graph Streaming API for Apache Flink☆141Oct 13, 2020Updated 5 years ago
- A flink project template using Scala and SBT☆26Nov 29, 2018Updated 7 years ago
- Stratosphere is now Apache Flink.☆198Dec 16, 2023Updated 2 years ago
- Example how to integrate Esper with Akka in the form of an Akka event bus☆29Jan 27, 2015Updated 11 years ago
- ☆46Aug 28, 2017Updated 8 years ago
- flink-jpmml is a fresh-made library for dynamic real time machine learning predictions built on top of PMML standard models and Apache Fl…☆97May 9, 2019Updated 6 years ago
- Spark pipelines that correspond to a series of Dataflow examples.☆27May 5, 2019Updated 6 years ago
- ☆14May 19, 2016Updated 9 years ago
- SBT plugin that routes compiler and test errors into a quickfix file☆55Jun 12, 2019Updated 6 years ago
- A dbt adapter for Decodable☆12Sep 4, 2025Updated 5 months ago
- ☆110Apr 17, 2017Updated 8 years ago