我想使用kll草图流应用程序。关键是kll草图是有状态的计算,因此不是幂等的。这可以用beam或flink实现吗,最好用python实现?apachedatasketch说,集成工作已经从apacheflink和apacheimpala开始。apachebeam也对此感兴趣。主要困难是什么?大多数草图在内部使用基本类型和数组。
k2arahey1#
您可以使用状态和计时器在流式波束管道中使用它。
1条答案
按热度按时间k2arahey1#
您可以使用状态和计时器在流式波束管道中使用它。