在python中使用带有apachebeam或apacheflink的草图

bvhaajcl  于 2021-06-21  发布在  Flink
关注(0)|答案(1)|浏览(270)

我想使用kll草图流应用程序。关键是kll草图是有状态的计算,因此不是幂等的。这可以用beam或flink实现吗,最好用python实现?
apachedatasketch说,集成工作已经从apacheflink和apacheimpala开始。apachebeam也对此感兴趣。主要困难是什么?大多数草图在内部使用基本类型和数组。

k2arahey

k2arahey1#

您可以使用状态和计时器在流式波束管道中使用它。

相关问题