Github user ijokarumawak commented on a diff in the pull request:
https://github.com/apache/nifi/pull/2518#discussion_r184277876
--- Diff:
nifi-nar-bundles/nifi-hbase-bundle/nifi-hbase-processors/src/main/java/org/apache/nifi/hbase/PutHBaseRecord.java
---
@@ -368,9 +412,18 @@ protected PutFlowFile createPut(ProcessContext
context, Record record, RecordSch
timestamp = null;
}
+ RecordField visField = null;
+ Map visSettings = null;
+ if (recordPath != null) {
+ final RecordPathResult result =
recordPath.evaluate(record);
+ FieldValue fv =
result.getSelectedFields().findFirst().get();
+ visField = fv.getField();
+ visSettings = (Map)fv.getValue();
+ }
+
List<PutColumn> columns = new ArrayList<>();
for (String name : schema.getFieldNames()) {
- if (name.equals(rowFieldName) ||
name.equals(timestampFieldName)) {
+ if (name.equals(rowFieldName) ||
name.equals(timestampFieldName) || (visField != null &&
name.equals(visField.getFieldName()))) {
--- End diff --
Good stuff, I'd expect PutHBaseJson has the same capability.
---
