AttributeRollingWindow

Описание

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

Теги

Attribute Expression Language, state, data science, rolling, window

Свойства

Название	Описание
Отслеживаемое значение	Выражение, на основании которого следует оценивать каждый файл FlowFile. Результат выражения будет добавлен к значению окна переменной. Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды)
Временное окно	Временное окно, на основании которого рассчитывается скользящее окно.
Длина подокна	Когда установлено, значения будут группироваться в подокна заданной длины. Это позволяет задать гораздо большую общую длину окон, но приводит к некоторой потере точности. Если это значение не задано (или равно 0), то каждое значение сохраняется в состоянии с отметкой времени, когда оно было получено. По истечении времени, значение будет удалено. Если это значение задано, значения будут объединяться каждые X промежутков времени (где X - период времени, установленный для этого свойства) и удаляться все сразу.

Взаимосвязи

• set state fail: Когда состояние не удается сохранить при обработке FlowFile, FlowFile перенаправляется сюда.
• success: Все FlowFile, успешно обработанные, перенаправляются сюда
• failure: Когда FlowFile выходит из строя по причине, отличной от сбоя установки состояния, он перенаправляется сюда.