#
1. Flink版本1.7.2 2. 引入依赖 使用maven构建工程，因此pom.xml添加如下依赖：
原文链接 Flink CEP 0. 本文概述简介 FlinkCEP是在Flink之上实现的复杂事件处理（CEP）库。 它允许你在×××的事件流中检测事件模式，让你有机会掌握数据中重要的事项。 本文描述
第二章 Data Processing Using the DataStream API （中英对照） &n
搞Java开发的同学，目标都想成为Java架构师；搞大数据开发的同学，目标都想成为大数据架构师。 成为大数据架构师有什么好处呢？ 归其原因： 1.技术上能达到一定的高度，被公司认可，也被社会认可，有成
动态路由:方案1: 定制一个特殊的KafkaDynamicSink，内嵌多个原生的FlinkKafkaProducer，每个对应一个下游的KAFKA队列在OPEN方法中读取所有KAFKA渠道配置并构建
作者: 刘迪珊 本文整理自8月11日在北京举行的Flink Meetup，分享嘉宾刘迪珊(2015年加入美团数据平台。致力于打造高效、易用的实时计算平台，探索不同场景下实时应用的企业级解决方案及统⼀化
Linux命令 我是小白，我从来没玩过Linux,请点这里： https://user-gold-cdn.xitu.io/2019/2/24/1691e1dda7807059 推荐的一个Git仓库 我
旁路输出(side output) 除了来自数据流算子的主流结果输出之外，可以产生任意数量的流旁路输出结果。旁路输出结果数据类型与主流结果的数据类型以及其他旁路输出结果数据类型可以是完全不同的。当
15年在某电商从0设计了一个通用的API监控系统，当时只是计算了成功率+平均耗时，没有算75,90,95,99,999,9999线，这次单位需要，所以促使我去思考这个问题，问了单位CAT维护人员，大致
SIDDHI 是一款功能强大的CEP 引擎，具有自己的DSL,丰富的模式匹配功能和可扩展性, 感谢陈浩同学提供了SIDDHI和FLINK的整合功能 https://github.com/haoch/f
