基于1.14.0进行的动态规则变更

大数据学习文档、实战代码、源码解析、测试数据,包含python、mysql、shell、hadoop、hive、zookeeper、hbase、flume、kafka、spark、flink、dolphinscheduler、elasticsearch、sqoop、clickhouse

记录学习大数据技术时的相关内容，以java相关技术为主

flinksql-connector-redis

springboot集成flink的简单demo

自己项目中用到的，从kafka获取数据，flink过滤数据后，存入到ES中

告警采集平台，Flink1.14.4，Kafka-2.8，ElasticSearch-7.3.2，Flink读取Kafka消息，实时检测三个场景，一是当前访问IP或者域名是否黑名单地址，二是当前连接端口是否敏感生产环境端口，三是检测一段时间内连续登录失败后突然又登录成功的场景。

基于Hadoop和Spark和Flink的大数据可视化分析和协同过滤推荐系统 各类的都有，创作不易，拒绝白嫖

基于java和flink实现实时指标计算功能

编写技术文档分享（linux、java、大数据、go、docker+k8s等）

Flink项目

Flink经典案例

关于flink的批处理和有界无界流处理实现的WordCount的Demo (仅供参考学习使用)

描述：turing-materials