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

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


person Viktor Stolbin    schedule 24.07.2018    source источник


Ответы (1)


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

person Can Gencer    schedule 24.07.2018