database - PutHBaseRecord 行标识符中的多个列名称 NiFi 中的字段名称属性

Question

我有一个从 Oracle 表中提取行并通过 NiFi 将其放入 Hbase 的简单流程。

要从数据库中提取数据，我正在使用“QueryDataBase 表”并将其放入 HBase，我正在使用“PutHbase 记录”处理器。

通常，无论我的表的主键是什么，我都将其用作 putHbaseRecord 中的“行标识符字段”。

当有复合主键时，我的问题就出现了，因为 putHbase 记录处理器中的行标识符字段属性没有采用多列。

这方面的任何帮助都会非常有帮助。

谢谢

Answer 1

不幸的是，目前 PutHBaseRecord 无法做到这一点。这需要对处理器进行代码更改以允许为行 ID 指定多个字段名称，然后它必须从每条记录中获取它们并将它们连接在一起以形成行 ID 值。

将属性设为创建行 ID 的记录路径表达式可能会更好。这样，如果您想要一个单一的值，您只需输入类似“/field1”的内容，如果您想要一个复合值，您可以执行类似“concat('/field1', '/field2')”的操作。