AI
推荐
模板社区
专题
登录
免费注册
首页
流程图
详情
流批一体指标计算
2021-05-30 18:22:59
1
举报
分享方式
使用 (￥3)
指标计算流批一体方案
flink
指标计算
模版推荐
作者其他创作
大纲/内容
EventIndicatorStream
input
窗口内通过状态维护想同主维度，相同时间分片粒度，指标集历史分片结果
EventResultStream
根据主维度keyby，时间分片粒度滚动窗口
output
消息队列
时间排序加载
实时加载
Flink Source
···
离线数据源
根据指标相关配置，状态中提取计算指标结果并附加到每一条数据中
根据主维度+分片粒度分组，遍历执行
提取时间字段作为Event Time
action
指标集
通过增量计算，对每一条数据对指标选择不同算子进行计算
每一条数据附加指标集所有结果
指标计算逻辑
transform
EvevntDataStream
收藏
立即使用
作业状态机
收藏
立即使用
大数据标准化处理流程
收藏
立即使用
流批一体指标计算
收藏
立即使用
ER表设计
哲2018
职业：本科
去主页
Collect
Get Started
湖仓一体架构
Collect
Get Started
情报一体化项目功能分解
Collect
Get Started
流批一体数据处理架构
Collect
Get Started
流批一体的ETL数据集成
评论
0
条评论
下一页
Document
