为什么用Groovy

Flink-CEP的底层是基于Non-deterministic Finite Automaton（NFA，非确定有限自动机）构建的，它是一种用来定义和描述不同状态转换过程的正则（表达式）语言。

对于那些短时长（统计区间一般在5~15分钟）和浅层操作（注册、登录、修改IP、修改用户名等）的行为，如果使用常规的实时计算方式，例如，从Kafka拉取数据 -> Flink实时计算 -> 指标保存到Redis -> 从Redis读取数据，就显得有些冗长了。