fzjc,github

bigdata-application

现已在移动行业部署的大数据应用项目【iop、智能短信、旅游应用、一经逍遥、实时驻留时长等】，技术栈：SparkStreaming、StructStreaming、Kafka、Hbase、Flume等

checkpointed-video-stream

A self-contained example that illustrates recovery of Spark Streaming from a checkpoint

cloud

云计算之hadoop、hive、hue、oozie、sqoop、hbase、zookeeper环境搭建及配置文件

datasets

Public datasets to use with the exercises in the book

delta

An open-source storage framework that enables building a Lakehouse architecture with compute engines including Spark, PrestoDB, Flink, Trino, and Hive and APIs

Apache DolphinScheduler is a distributed and extensible workflow scheduler platform with powerful DAG visual interfaces, dedicated to solving complex job dependencies in the data pipeline and providing various types of jobs available `out of the box`.

doris

Apache Doris is an easy-to-use, high performance and unified analytics database.

dt-sql-parser

SQL Parsers for BigData, built with antlr4.

easy-algorithm-interview-and-practice

flink

Mirror of Apache Flink

flink-cdc

CDC（变化数据捕获）实时同步方案，秒级延迟。

flink-commodity-recommendation-system

:whale:基于 Flink 的商品实时推荐系统。使用了 redis 缓存热点数据。当用户产生评分行为时，数据由 kafka 发送到 flink，根据用户历史评分行为进行实时和离线推荐。实时推荐包括：基于行为和实时热门，离线推荐包括：历史热门、历史优质商品和 itemcf 。

flink-doc-zh

Apache Flink 中文文档

flink-learning

flink learning blog. http://www.54tianzhisheng.cn/ 含 Flink 入门、概念、原理、实战、性能调优、源码解析等内容。涉及 Flink Connector、Metrics、Library、DataStream API、Table API & SQL 等内容的学习案例，还有 Flink 落地应用的大型项目案例（PVUV、日志存储、百亿数据实时去重、监控告警）分享。欢迎大家支持我的专栏《大数据实时计算引擎 Flink 实战与性能优化》

flink-practice

log、event 、time 、window 、table、sql、connect、join、async IO、维表、CEP

flink-recommandsystem-demo

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