Апачский шторм : Stateful Window - PullRequest
0 голосов
/ 30 ноября 2018

Q1: Поддерживает ли версия Storm 1.2.1 окно с состоянием и контрольную точку окна?Смотрите только соответствующее введение в версии 2.0.0.Например, withPersistence() контрольной точки окна в документе 2.0.0 не существует в версии 1.2.1.

Q2 : Должен ли я установить withMessageIdField() при использовании statefulwindow?Если я использую kafkaspout, я должен использовать withMessageIdField(offset)?

Q3 : Расчет окна заключается в кэшировании всех соответствующих кортежей.После триггера вызывается метод excute, и затем вычисляются все кэшированные кортежи вместо вычисления одного кортежа.Я прав?

...