Nifi QueryRecord для массива строк содержит значение

Возможное решение с 2 процессорами (ScriptedTransformProcessor -> QueryRecord):

ScriptedTransformProcessor (добавьте новое поле tags_str, объединив все элементы в tags с разделителем |)

• Script Language: Groovy
• Script Body:

record.setValue('tags_str', record.getValue('tags').join("|"))
record

Выход (JSON):

[ {
  "name" : "bob",
  "tags" : [ "/test1/foo", "/alpha" ],
  "tags_str" : "/test1/foo|/alpha"
}, {
  "name" : "bill",
  "tags" : [ "/test2/blah", "/beta" ],
  "tags_str" : "/test2/blah|/beta"
} ]

QueryRecord (фильтр)

• фильтр (динамическое свойство):

SELECT name, tags 
FROM FLOWFILE 
WHERE tags_str LIKE '%/test2/%'

вывод (JSON):

[ {
  "name" : "bill",
  "tags" : [ "/test2/blah", "/beta" ]
} ]