Цапля TumblingWindowBolt на основе количества секунд

Question

Документация Heron гласит, что можно реализовать Tumbling Windows на основе количества.Однако heronpy.api.bolt.window_bolt.TumblingWindowBolt имеет только поле WINDOW_DURATION_SECS.Как я могу реализовать TumblingWindowBolt на основе количества кортежей?

Answer 1

Кажется, в Python API эта функция еще не реализована. Java имеет лучшую поддержку функций, если это вариант для вас.