流批一体指标计算
2021-05-30 18:22:59 1 举报指标计算流批一体方案
作者其他创作
大纲/内容
EventIndicatorStream
input
窗口内通过状态维护想同主维度，相同时间分片粒度，指标集历史分片结果
EventResultStream
根据主维度keyby，时间分片粒度滚动窗口
output
消息队列
时间排序加载
实时加载
Flink Source
···
离线数据源
根据指标相关配置，状态中提取计算指标结果并附加到每一条数据中
根据主维度+分片粒度分组，遍历执行
提取时间字段作为Event Time
action
指标集
通过增量计算，对每一条数据对指标选择不同算子进行计算
每一条数据附加指标集所有结果
指标计算逻辑
transform
EvevntDataStream
0 条评论
下一页
