Queryable State
时间: 2023-11-22 21:48:48 浏览: 36
Queryable State是指在分布式流处理系统中,可以通过查询来获取和检索的状态。在激活集群的queryable state功能后,需要将state设置为可查询的才能对外可见。有两种设置方式可以实现这一目的。
第一种方式是通过创建一个QueryStateStream,它作为一个sink,将输入数据转换为queryable state。可以使用asQueryableState方法来创建QueryStateStream,并传入查询状态的名称和状态描述符。对于不同类型的状态,可以使用不同的方法,如ValueState、ReducingState等。
第二种方式是通过stateDescriptor.setQueryable(String queryableStateName)方法,将state描述符所表示的keyed state设置为可查询的。这种方式可以在代码中具体实现,通过KeyedStream对象的asQueryableState方法来获取QueryableStateStream对象,从而提供可查询的状态值。
综上所述,Queryable State是指在分布式流处理系统中可以通过查询来获取和检索的状态。可以通过创建QueryStateStream或设置state描述符来实现状态的可查询性。
#### 引用[.reference_title]
- *1* [Flink state(3)- Queryable State](https://blog.csdn.net/weixin_46021633/article/details/119036354)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v91^insert_down1,239^v4^insert_chatgpt"}} ] [.reference_item]
- *2* *3* [Flink(九) 状态可查询 Queryable State](https://blog.csdn.net/weixin_44079636/article/details/119765090)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v91^insert_down1,239^v4^insert_chatgpt"}} ] [.reference_item]
[ .reference_list ]