我需要实现bloomfilter作为apacheflink的状态,我使用 ValueState
它包含一个bloomfilter示例,每次我都更新state的值。
state = getRuntimeContext.getState(
new ValueStateDescriptor[BloomFilter](
"value-bloomfilter",
createTypeInformation[BloomFilter]
)
)
但是我需要更有效的方法,比如定制状态。不幸的是,我找不到任何关于如何为ApacheFlink开发原始状态的资源。
暂无答案!
目前还没有任何答案,快来回答吧!