Чтение пользовательского свойства в процессоре

Question

Я пытаюсь создать собственный процессор (с Java) в Apache Nifi для чтения пользовательского свойства пользователя.Можно ли создать процессор для извлечения пары ключ-значение пользователя?Если да, то как мне их извлечь?

Сохраняются ли пользовательские пользовательские свойства в словаре в библиотеке какого-либо nifi.processor. *?

См. Изображение ниже:

В идеале я хочу извлечь динамические значения Свойство и Значение для всех входных данных выше.то есть.{"Пользовательское свойство 1": "Некоторое значение", "Пользовательское свойство 2": "Другое значение", "Пользовательское свойство 3": "Третье значение"}

Answer 1

Определяемые пользователем свойства доступны в вашем ProcessContext, как и все свойства, но они имеют флаг dynamic. Вот фрагмент для перебора пользовательских свойств:

context.getProperties().keySet().stream().filter(PropertyDescriptor::isDynamic).forEach()

Заполните лямбду в forEach() своей логикой для обработки свойств.