flink算子状态类型

深碍√TFBOYSˉ_ 2023-01-19 03:22 3阅读 0赞

1、flink自己管理的算子状态类型有以下几种,

BroadcastState,ListState,UnionListState

  1. package org.apache.flink.api.common.state;
  2. import java.util.Set;
  3. import org.apache.flink.annotation.PublicEvolving;
  4. @PublicEvolving
  5. public interface OperatorStateStore {
  6. <K, V> BroadcastState<K, V> getBroadcastState(MapStateDescriptor<K, V> var1) throws Exception;
  7. <S> ListState<S> getListState(ListStateDescriptor<S> var1) throws Exception;
  8. <S> ListState<S> getUnionListState(ListStateDescriptor<S> var1) throws Exception;
  9. Set<String> getRegisteredStateNames();
  10. Set<String> getRegisteredBroadcastStateNames();
  11. }

2、上述的状态就设计flink的状态恢复问题,具体恢复可以参照以下文章

https://blog.csdn.net/lvwenyuan_1/article/details/98511963

发表评论

表情:
评论列表 (有 0 条评论,3人围观)

还没有评论,来说两句吧...

相关阅读