TouK/nussknacker

Low-code tool for automating actions on real time data | Stream processing for the users.

Language: Scala - Size: 186 MB - Last synced at: 4 days ago - Pushed at: 4 days ago - Stars: 691 - Forks: 99

water8394/flink-recommandSystem-demo

:helicopter::rocket:基于Flink实现的商品实时推荐系统。flink统计商品热度，放入redis缓存，分析日志信息，将画像标签和实时记录放入Hbase。在用户发起推荐请求后，根据用户画像重排序热度榜，并结合协同过滤和标签两个推荐模块为新生成的榜单的每一个产品添加关联产品，最后返回新的用户列表。

Language: Java - Size: 4.47 MB - Last synced at: 11 days ago - Pushed at: over 1 year ago - Stars: 4,389 - Forks: 1,476

mikeroyal/Apache-Flink-Guide

Apache Flink Guide

Size: 171 KB - Last synced at: about 2 months ago - Pushed at: over 3 years ago - Stars: 57 - Forks: 8

crate/cratedb-flink-jobs

This repository accompanies the article "Build a data ingestion pipeline using Kafka, Flink, and CrateDB" and the "CrateDB Community Day #2".

Language: Java - Size: 8.48 MB - Last synced at: 3 months ago - Pushed at: 3 months ago - Stars: 5 - Forks: 3

yyb345/notes

大数据&后端技术体系笔记【多回顾、多练习、多总结沉淀】

Language: Java - Size: 38 MB - Last synced at: 9 months ago - Pushed at: 9 months ago - Stars: 2 - Forks: 0

suryadev99/stream_processing_website_click_data

Stream Processing of website click data using Kafka and monitored and visualised using Prometheus and Grafana

Language: Python - Size: 508 KB - Last synced at: 3 months ago - Pushed at: 11 months ago - Stars: 0 - Forks: 0

threeknowbigdata/flink_second_understand

该仓库专注于让读者秒懂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=getalbum&album_id=2038088622687469575#wechat_redirect

Language: Java - Size: 58.7 MB - Last synced at: 12 months ago - Pushed at: 12 months ago - Stars: 646 - Forks: 174

BrooksIan/Flink2Kafka

A Flink applcation that demonstrates reading and writing to/from Apache Kafka with Apache Flink

Language: Java - Size: 2.98 MB - Last synced at: 2 months ago - Pushed at: almost 2 years ago - Stars: 20 - Forks: 7

LinMingQiang/sparkstreaming

:boom: :rocket: 封装sparkstreaming动态调节batch time(有数据就执行计算)；:rocket: 支持运行过程中增删topic；:rocket: 封装sparkstreaming 1.6 - kafka 010 用以支持 SSL。

Language: Scala - Size: 258 KB - Last synced at: about 1 year ago - Pushed at: about 4 years ago - Stars: 182 - Forks: 83

seanpquig/flink-streaming-confluent

DeserializationSchema compatible with Confluent's KafkaAvroDecoder

Language: Java - Size: 16.6 KB - Last synced at: almost 2 years ago - Pushed at: about 9 years ago - Stars: 5 - Forks: 3

zqhxuyuan/kafka-book

《Kafka技术内幕》代码

Language: Java - Size: 816 KB - Last synced at: over 1 year ago - Pushed at: over 7 years ago - Stars: 195 - Forks: 71

isopropylcyanide/Websockets-Vertx-Flink-Kafka

A simple request response cycle using Websockets, Eclipse Vert-x server, Apache Kafka, Apache Flink.

Language: Java - Size: 85.4 MB - Last synced at: about 1 month ago - Pushed at: about 4 years ago - Stars: 16 - Forks: 7

sonhmai/streaming-pipeline

Building POC of streaming pipeline with Flink, Kafka, Pinot

Language: Scala - Size: 37.1 KB - Last synced at: over 2 years ago - Pushed at: over 2 years ago - Stars: 2 - Forks: 0

froblesmartin/BachFinalProject

Project to compare Apache Spark Streaming vs Apache Flink.

Language: Java - Size: 42 KB - Last synced at: about 2 years ago - Pushed at: about 4 years ago - Stars: 1 - Forks: 1

yucl80/log-handle-tools

Language: Scala - Size: 133 KB - Last synced at: 3 months ago - Pushed at: almost 8 years ago - Stars: 0 - Forks: 1