状态计算概念

状态类型与应用

状态应用场景

deduplication(record all primary keys去重)
window computing(included but untriggered data计算)
machine、deep learning(training model and parameter训练模型和参数)
history data access(comparison with yesterday’s data is required 对比昨天的数据)

状态类型分类

实时交易反欺诈项目

需求

1.能够根据规则去动态的计算数据(需要broadcast state动态更新应用计算规则,根据规则实现数据动态分区即keyby)
2.自定义窗口保证低延时触发报警
技术栈:flink+kafka+backend+frontend
1638239624(1).png
1638241040(1).png