Q1: Поддерживает ли версия Storm 1.2.1 окно с состоянием и контрольную точку окна?Смотрите только соответствующее введение в версии 2.0.0.Например, withPersistence()
контрольной точки окна в документе 2.0.0 не существует в версии 1.2.1.
Q2 : Должен ли я установить withMessageIdField()
при использовании statefulwindow?Если я использую kafkaspout, я должен использовать withMessageIdField(offset)
?
Q3 : Расчет окна заключается в кэшировании всех соответствующих кортежей.После триггера вызывается метод excute, и затем вычисляются все кэшированные кортежи вместо вычисления одного кортежа.Я прав?