Вы можете иметь GetHBase
и подключить его к EvaluateJsonPath
(поскольку GetHBase выводит результат в формате JSON), чтобы получить идентификатор строки, а затем использовать идентификатор строки в FetchHBaseRow
, задав динамическое имя атрибута, используемое в EvalueteJsonPath всвойство Row Identifier
в FetchHBaseRow.
В моем примере я упоминал, что EvaluateJsonPath
используется для чтения ключа строки, но вы можете использовать допустимое выражение Json Path для чтения любых значений из вывода GetHBase ииспользуй это.
Поток пробы
![Sample Flow](https://i.stack.imgur.com/b0Gli.jpg)
Ключ чтения строки
Используя EvaluateJsonPath, мы читаем ключ строки из вывода JSON процессором GetHBase
.Убедитесь, что для Destination
установлено значение flowfile-attribute
![Reading Row Key](https://i.stack.imgur.com/dHZQD.jpg)
Использование обработанного ключа строки
Мыпрочитайте ключ строки и поместите его в атрибут row.key
.Здесь мы используем этот атрибут в свойстве Row Identifier
в FetchHBaseRow
![Using parsed Row key](https://i.stack.imgur.com/dBhnU.jpg)