Идентификатор строки с несколькими полями в PutHBaseRecord в Apache Nifi - PullRequest
Новая
       1

Идентификатор строки с несколькими полями в PutHBaseRecord в Apache Nifi

0 голосов
/ 05 марта 2019

У меня есть такой массив Json; 

[
    {
        "item_id": "",
        "timestamp": "",
        "type": "",
        "value": ""
    },
    {
        "item_id": "",
        "timestamp": "",
        "type": "",
        "value": ""
    }
]

Я хочу создать ключ строки для HBase следующим образом: : тип отметки времени item_id

Но PutHBaseRecord ждет одногополе от меня.Что я могу сделать?

Могу ли я сделать что-то подобное?

Для считывателя записей = JsonPathReader

И, rowId = concat ($ item_id, $ timestamp, $ type) ????

1 Ответ

2 голосов
/ 05 марта 2019

Использовать UpdateRecord процессор до PutHbaseRecord процессор.

Определяет Контроллер устройства записи / записи служб для включения вновь добавленного поля(row_id)

Добавить новое свойство в процессоре UpdateRecord как 

rowId

concat(/item_id, /timestamp, /type)

Затем в PutHBaseRecord процессор использовать rowId вместо Row Identifier Field Name значения свойства.

См. эту ссылку для настройки / использования процессора UpdateRecord

...