Flink实现状态数据互相访问(即依赖数据访问，相似表之间的Join)

在流处理应用中，对单个event的处理若是不涉及与其余event交互或访问是比较简单的。可是若是对单个event的处理依赖其余topic过来的event或者后续处理的event依赖当前处理的event，这种情景相似于多表之间join，A和B join取A表的某几个字段。使用flink的state就能够实现。java 一个场景以下：apache      课程信息(table,class_id,cl

>>阅读原文<<