REST job server for Apache Flink

Dinky is an out of the box one-stop real-time computing platform dedicated to the construction and practice of Unified Streaming & Batch and Unified Data Lake & Data Warehouse. Based on Apache Flink, Dinky provides the ability to connect many big data frameworks including OLAP and Data Lake.

BitSail is a distributed high-performance data integration engine which supports batch, streaming and incremental scenarios. BitSail is widely used to synchronize hundreds of trillions of data every day.

Apache Flink

大数据知识仓库涉及到数据仓库建模、实时计算、大数据、数据中台、系统设计、Java、算法等。

Support agile DataOps Based on DataX and Flink-CDC, Chunjun with Web-UI

Web-based notebook that enables data-driven, interactive data analytics and collaborative documents with SQL, Scala and more.

Apache Flink Kubernetes Operator

Machine learning library of Apache Flink

A visual tool to define and run real-time decision algorithms. Brings agility to business teams, liberates developers to focus on technology.

Yet Another UserAgent Analyzer

Benchmarks for Nussknacker - A visual tool to define and run real-time decision algorithms. Brings agility to business teams, liberates developers to focus on technology.

Cloud Native DataOps & AIOps Platform | 云原生数智运维平台

Taier is a big data development platform for submission, scheduling, operation and maintenance, and indicator information display

CSDN博客专家程序员欣宸的github，这里有六百多篇原创文章的详细分类和汇总，以及对应的源码，内容涉及Java、Docker、Kubernetes、DevOPS等方面

When Apache Pulsar meets Apache Spark

A data generator source connector for Flink SQL based on data-faker.

Big Data RDF Processing and Analytics Stack built on Apache Spark and Apache Jena http://sansa-stack.github.io/SANSA-Stack/

Easy parsing of Apache HTTPD and NGINX access logs with Java, Hadoop, Hive, Pig, Flink, Beam, Storm, Drill, ...

This repository contains the ingredients for the Digital Twin Concept of Industry Fusion.

Kotlin support for Apache Flink

CDC(Change Data Capture) is made up of two components, the CDD and the CDT. CDD is stand for Change Data Detection and CDT is stand for Change Data Transfer.

Apache flink

Apache Flink connectors for Pravega.

Flink SQL connector for ClickHouse. Support ClickHouseCatalog and read/write primary data, maps, arrays to clickhouse.

Kubernetes operator for managing the lifecycle of Apache Flink and Beam applications.

A data integration framework

Example setup to demonstrate Prometheus integration of Apache Flink

Schema Registry

LakeSoul is an end-to-end, realtime and cloud native Lakehouse framework with fast data ingestion, concurrent update and incremental data analytics on cloud storages for both BI and AI applications.