Фильтрация - это просто преобразование, в котором вы решаете ничего не выводить. Вы указываете это, отправляя результат со значением "Dropped" согласно документации .
Вы можете найти в этом посте пример преобразования, и логика включает в себя несколько вещей: пропуск записей без какого-либо преобразования (состояние "OK"), преобразование и вывод записи (снова, статус "OK"), удаление или фильтрация записи (статус "Dropped") и сообщение об ошибке с использованием статуса "ProcessingFailed"