flink-streaming 开源项目推荐（45 个）

threeknowbigdata /flink_second_understand

该 仓 库 专 注 于 让 读 者 了解 F link 组 件 ， 包括 F link 实 战 代 码 和 文 档 ，200 个 F link 教 程 知识 点 ， F link Dat astre am ， F link Table ， F link Window ， F link State ， F link Check point ， F link Met rics ， F link Memory ， F link on stand al one/yar n/k 8 s ， F link SQL ， F link CE P ， F link CDC ， F link U DF ， P y F link ， F link New Fe atures ， F link Part ition ， F link Memory 等 知识 点 。 详 细 链 接 请 参 见 ： htt ps ：//mp.weixin.qq.com/mp/ app ms gal bum ？ _ _我们 是 M zg 5 ND Y 3 Nz I w MA == & action = get album & album _ id = 203 80 88 6 22 68 7 46 95 75 # we chat _ red irect

mikeroyal /Apache-Flink-Guide

Apache Flink 指南

factorhouse /factorhouse-local

该项目在 GitHub 上没有填写描述

felipegutierrez /explore-flink

本项目使用 Apache Flink 作为流引擎，从文件系统或 Kafka broker 消费数据，并通过 Prometheus 和 Grafana 暴露指标，所有内容均部署在 Kubernetes（minikube）上。

PlanetCassandra /Cassandra.Realtime

使用 Kafka、Spark、Akka、Flink 等技术将数据实时处理到 Cassandra 的不同方式

ClickHouse /flink-connector-clickhouse

ClickHouse 的官方 Apache Flink 连接器

flink-extended /clink

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.

cjermain /flink-onnx-pytorch

Streaming machine learning using PyTorch, Flink, and ONNX

AhmetFurkanDEMIR /Flink-Example

Flink Example

innogames /flink-real-time-crm

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.

DataSystemsGroupUT /Adaptive-Watermarks

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

ev2900 /Flink_Kinesis_Data_Analytics

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

mattczyz /flink-orc

Adds ORC support to Flink Streaming File Sink

Quocc1 /Stream_Processing

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

Java-Edge /Flink-Tutorial

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

zsolt-donca /flink-alt

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

wuzguo /hadoop-study

hadoop study project

TawfikYasser /Keyed-Watermarks-in-Apache-Flink

Keyed Watermarks in Apache Flink

nkonev /flink-pipe

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.

john-papani /IoT-Live-streaming

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