开发者社区> 问答> 正文

Flink状态原语中的Keyed State的使用方法是什么呢?

Flink状态原语中的Keyed State的使用方法是什么呢?

展开
收起
游客vqgchj4kfdzsu 2021-12-08 20:51:55 522 0
1 条回答
写回答
取消 提交回答
  • 键控状态是根据输入数据流中定义的键(key)来维护和访问的。

    Flink 为每个键值维护一个状态实例,并将具有相同键的所有数据,都分区到同一个算 子任务中,这个任务会维护和处理这个 key 对应的状态。当任务处理一条数据时,它会自动 将状态的访问范围限定为当前数据的 key。因此,具有相同 key 的所有数据都会访问相同的 状态。

    2021-12-08 22:31:09
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载