Это то, чего я пытаюсь достичь. все они являются файлами CSV
Flowfile (CSV) -
col1_raw, col2_raw, col3_raw, col4_raw
1 , 2 , 3 , 4
1 , 2 , 3 , 4
Поиск файла1 (CSV)
col_name_raw , col_name_business, class
col1_raw , col1_business , Secret
col2_raw , col2_business , Public
col3_raw , col3_business , Secret
col4_raw , col4_business , Public
Поиск файла 2 (CSV)
class, action
public, copy
secret, nocopy
вывод (csv) потока файла должен быть
col2_business, col4_business
2, 4
2, 4
Так что в основном я Я фильтрую столбцы потокового файла на основе указанного в списке действий файла поиска2. Также изменив необработанное имя столбца на имя бизнес-столбца в соответствии с файлом поиска1. В SQL это очень просто, но в Nifi как я могу добиться этого, используя существующие процессоры. Пожалуйста помоги.