如何为ApacheFlink开发原始键控状态?

vs3odd8k  于 2021-06-25  发布在  Flink
关注(0)|答案(0)|浏览(170)

我需要实现bloomfilter作为apacheflink的状态,我使用 ValueState 它包含一个bloomfilter示例,每次我都更新state的值。

state = getRuntimeContext.getState(
      new ValueStateDescriptor[BloomFilter](
         "value-bloomfilter", 
         createTypeInformation[BloomFilter]
      )
)

但是我需要更有效的方法,比如定制状态。不幸的是,我找不到任何关于如何为ApacheFlink开发原始状态的资源。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题