flink算子状态类型

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

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

BroadcastState，ListState，UnionListState

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

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

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

发表评论

表情：
评论列表 （有 0 条评论，2人围观）

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

相关阅读