FILTER
FILTER фильтрует входные данные в соответствии с логическим выражением. Отправляет все записи, соответствующие выражению фильтра, в первый выходной порт и все отклоненные записи во второй выходной порт.
Порты FILTER:
| Тип порта | Номер | Обязательный | Описание | Метаданные |
|---|---|---|---|---|
| Input | 0 | да | Для входящего потока записей | Одинаковые метаданные на входных и выходных портах |
| Output | 0 | да | Для отфильтрованных записей | |
| 1 | нет | Для отклонённых записей |
Атрибуты FILTER:
| Атрибут | Обязательный | Описание | Возможные значения |
|---|---|---|---|
| filterExpression | да | Выражение, по которому фильтруются записи. |
|
Пример. Фильтрация данных.
Входные данные содержат данные о продуктах, проданных в прошлом году. Нужно узнать данные только по карандашам. Метаданные содержат поля Product, Count и Location.
Входящие записи:
| Product | Count | Location |
|---|---|---|
| карандаш | 1553 | екатеринбург |
| бумага | 6475 | новгород |
| ручка | 598 | владикавказ |
| карандаш | 177 | омск |
| карандаш | 239 | волгоград |
| бумага | 19 | казань |
| ластик | 53 | ростов |
Решение:
Выражение для фильтрации: $in[0].product == "карандаш"
Исходящие записи:
| Product | Count | Location |
|---|---|---|
| карандаш | 1553 | екатеринбург |
| карандаш | 177 | омск |
| карандаш | 239 | волгоград |