Flink 的编程模型与其他框架比较

Flink 的核心语义和架构模型 Flink核心概念 Streams(流) 有界流 有固定大小,不随时间增长而增长的数据,比如Hive中的一张表 无界流 无固定大小,数据随时间增长而增长,比如Kafka中的消息 State(状态)#重要 指的是在进行流式计算过程中的信息,一般用作容错恢复和持久化。因为流式计算本质是增量计算,也就是说需要不断查询过去的状态 Time(时间) Flink 支持了 Ev
相关文章
相关标签/搜索