Несколько имен столбцов в свойстве Имя поля идентификатора строки PutHBaseRecord в NiFi

Question

У меня есть простой процесс извлечения строк из таблицы Oracle и помещения их в Hbase через NiFi.

Для извлечения данных из БД я использую «Таблицу QueryDataBase» и помещаю в HBase Я использую процессор «PutHbase Record».

Обычно, какой бы ни был первичный ключ моей Таблицы, я использую его как «Поле идентификатора строки» в putHbaseRecord.

Моя проблема возникает при наличии составного первичного ключа, поскольку свойство поля идентификатора строки в процессоре записи putHbase не принимает несколько столбцов.

Любая помощь в этом будет очень полезна.

Спасибо

Answer 1

К сожалению, в настоящее время это невозможно с PutHBaseRecord. Потребуется изменение кода процессора, чтобы можно было указывать несколько имен полей для идентификатора строки, а затем он должен был бы получить их и из каждой записи и объединить их вместе, чтобы сформировать значение идентификатора строки.

Может быть, лучше сделать свойство выражением пути записи, которое создает идентификатор строки. Таким образом, если вам нужно одно значение, вы просто помещаете что-то вроде '/ field1' и если вы хотите составное значение, вы делаете что-то вроде "concat ('/ field1', '/field2')".