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

该仓库专注于让读者秒懂Flink组件，包含Flink实战代码和文档、200个Flink教程知识点，Flink Datastream、Flink Table、Flink Window、Flink State、Flink Checkpoint、Flink Metrics、Flink Memory、Flink on standalone /yarn/k8s、Flink SQL、Flink CEP、Flink CDC、Flink UDF、PyFlink、Flink新特性、Flink Partition、Flink Memory等知识点。详细链接请看：https ://mp.weixin.qq.com/mp /appmsgalbum?__biz=Mzg5NDY3NzIwMA==&action=g…

Apache Flink Guide

This project uses Apache Flink as a stream engine that consumes data from the File system or Kafka brokers and exposes metrics using Prometheus and Grafana, everything deployed on Kubernetes (minikube).

Different ways to process data into Cassandra in realtime with technologies such as Kafka, Spark, Akka, Flink

Clink is a library that provides APIs and infrastructure to facilitate the development of parallelizable feature engineering operators that can be used in both C++ and Java runtime.

Streaming machine learning using PyTorch, Flink, and ONNX

Demo Flink and Kafka project to show how to react on tracking events in real-time and trigger offer for customer engagement based on campaign configurations. The project also utilizes the Broadcast State Pattern in order to update the rules (campaigns) at runtime without restarting the project, using a dedicated, low-frequency, Kafka topic.

Flink Example

Apache Flink examples designed to be run by AWS Kinesis Data Analytics (KDA).

An approach to apply concept drifts and ADWIN on the streams event time to reason about the progress of watermarks

Adds ORC support to Flink Streaming File Sink

第四代大数据计算引擎Flink - 从入门到实战

An alternative minimalistic API for Flink based on cats typeclasses, with a reference in-memory implementation.

This project aimed at providing real-time click attribution and dynamic e-commerce insights.

hadoop study project

Keyed Watermarks in Apache Flink

Information Systems, Analysis and Design Class Projects (2022-23, Fall Semester)

实时事件分析与决策引擎（Real-time event analysis and decision engine）

A [single|uber|fat] jar standalone Apache Flink connected to PostgreSQL via Ververica CDC connector. Usage Flink SQL to replicate data from PostgreSQL to Elasticsearch/something else.