- 流数据
- 持续到达
- 无限增长
- 到达次序独立
- 流计算
使用flink处理流数据
- watermark 衡量时间进制的标准
- 时间窗口：10s
- 容错机制
CEP介绍
基于flink任务
ex:
实时营销：
用户第一次激活几小时内触发某个行为
def：
- complex Event Process
- 对象：append-only time-ordered sequence of events
- 机制： continuous
- CEP与SQL
解决什么问题
- 过滤掉不满足条件的时间， 找到符合filter定义的事件
- eg: 从还款事件中筛选出逾期还款事件
- 找到符合pattern的事件
- eg:贷款申请审批通过一小时后未提款
- 事件流join数据表
- 筛选出贷款事件中的女性用户
- 窗口聚合
CEP平台（ICEYE）
- 事件配置
- 规则定义
- 结果消费
应用
- Trident实时营销
- 后裔实时报表