🚁🚀基于Flink实现的商品实时推荐系统。flink统计商品热度，放入redis缓存，分析日志信息，将画像标签和实时记录放入Hbase。在用户发起推荐请求后，根据用户画像重排序热度榜，并结合协同过滤和标签两个推荐模块为新生成的榜单的每一个产品添加关联产品，最后返回新的用户列表。
该仓库专注于让读者秒懂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、Fli...
Low-code tool for automating actions on real time data | Stream processing for the users.
💥 🚀 封装sparkstreaming动态调节batch time(有数据就执行计算)；🚀 支持运行过程中增删topic；🚀 封装sparkstreaming 1.6 - kafka 010 用以支持 SSL。
A Flink applcation that demonstrates reading and writing to/from Apache Kafka with Apache Flink
A simple request response cycle using Websockets, Eclipse Vert-x server, Apache Kafka, Apache Flink.
This repository accompanies the article "Build a data ingestion pipeline using Kafka, Flink, and CrateDB" and the "CrateDB Community Day #2".
基于Flink流处理的动态实时亿级电商全端用户画像系统
Building POC of streaming pipeline with Flink, Kafka, Pinot
DeserializationSchema compatible with Confluent's KafkaAvroDecoder
Process streaming data from Kafka with Flink and store it in ElasticSearch
#算法刷题#大数据+AI+后端技术体系笔记
Project to compare Apache Spark Streaming vs Apache Flink.
This code helps making a real time alert platform for IoT etc.
This is a basic example to show CEP in flink with kafka
Stream Processing of website click data using Kafka and monitored and visualised using Prometheus and Grafana
