Hazelcast Jet раздвижная оконная единица измерения

Question

Извините за, может быть, глупый вопрос, но из документов неясно, какова единица измерения для скользящего окна? Это миллисекунды, секунды или количество элементов в потоке? Я заметил, что операция агрегации давала пустые результаты, и мне пришлось явно фильтровать их, потому что, вероятно, для этого окна не было доступных данных, поэтому я думаю, что последний пункт - не вариант.

Answer 1

Jet не указывает единицу измерения для окон, вместо этого окна рассчитываются на основе той же единицы измерения, в которой указаны ваши временные метки. Обычно, если ваши временные метки являются временными метками в стиле UNIX, то это будут миллисекунды, но вы также можете использовать наносекунды, секунды или минуты, если так определены ваши метки времени. Он относится конкретно к времени события и не связан с количеством событий в потоке, а только с их временными метками.