Repository: nifi Updated Branches: refs/heads/master 1803c15bc -> 18a4819d5
NIFI-5290 - PutKudu should support unixtime_micros columns Signed-off-by: Pierre Villard <pierre.villard...@gmail.com> This closes #2781. Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/18a4819d Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/18a4819d Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/18a4819d Branch: refs/heads/master Commit: 18a4819d51df3c00523f28f7b120b7e535860e47 Parents: 1803c15 Author: Junegunn Choi <junegun...@gmail.com> Authored: Mon Jun 11 12:19:13 2018 +0900 Committer: Pierre Villard <pierre.villard...@gmail.com> Committed: Mon Jun 11 09:40:38 2018 +0200 ---------------------------------------------------------------------- .../src/main/java/org/apache/nifi/processors/kudu/PutKudu.java | 1 + .../test/java/org/apache/nifi/processors/kudu/TestPutKudu.java | 3 +++ 2 files changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/18a4819d/nifi-nar-bundles/nifi-kudu-bundle/nifi-kudu-processors/src/main/java/org/apache/nifi/processors/kudu/PutKudu.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-kudu-bundle/nifi-kudu-processors/src/main/java/org/apache/nifi/processors/kudu/PutKudu.java b/nifi-nar-bundles/nifi-kudu-bundle/nifi-kudu-processors/src/main/java/org/apache/nifi/processors/kudu/PutKudu.java index eb35e6d..108f5cf 100644 --- a/nifi-nar-bundles/nifi-kudu-bundle/nifi-kudu-processors/src/main/java/org/apache/nifi/processors/kudu/PutKudu.java +++ b/nifi-nar-bundles/nifi-kudu-bundle/nifi-kudu-processors/src/main/java/org/apache/nifi/processors/kudu/PutKudu.java @@ -125,6 +125,7 @@ public class PutKudu extends AbstractKudu { row.addInt(colIdx, record.getAsInt(colName)); break; case INT64: + case UNIXTIME_MICROS: row.addLong(colIdx, record.getAsLong(colName)); break; case STRING: http://git-wip-us.apache.org/repos/asf/nifi/blob/18a4819d/nifi-nar-bundles/nifi-kudu-bundle/nifi-kudu-processors/src/test/java/org/apache/nifi/processors/kudu/TestPutKudu.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-kudu-bundle/nifi-kudu-processors/src/test/java/org/apache/nifi/processors/kudu/TestPutKudu.java b/nifi-nar-bundles/nifi-kudu-bundle/nifi-kudu-processors/src/test/java/org/apache/nifi/processors/kudu/TestPutKudu.java index 315a0ee..1263c0e 100644 --- a/nifi-nar-bundles/nifi-kudu-bundle/nifi-kudu-processors/src/test/java/org/apache/nifi/processors/kudu/TestPutKudu.java +++ b/nifi-nar-bundles/nifi-kudu-bundle/nifi-kudu-processors/src/test/java/org/apache/nifi/processors/kudu/TestPutKudu.java @@ -330,6 +330,7 @@ public class TestPutKudu { new ColumnSchemaBuilder("id", Type.INT64).key(true).build(), new ColumnSchemaBuilder("name", Type.STRING).nullable(true).build(), new ColumnSchemaBuilder("age", Type.INT16).nullable(false).build(), + new ColumnSchemaBuilder("updated_at", Type.UNIXTIME_MICROS).nullable(false).build(), new ColumnSchemaBuilder("score", Type.DECIMAL).nullable(true).typeAttributes( new ColumnTypeAttributes.ColumnTypeAttributesBuilder().precision(9).scale(0).build() ).build())); @@ -338,12 +339,14 @@ public class TestPutKudu { new RecordField("id", RecordFieldType.BIGINT.getDataType()), new RecordField("name", RecordFieldType.STRING.getDataType()), new RecordField("age", RecordFieldType.SHORT.getDataType()), + new RecordField("updated_at", RecordFieldType.BIGINT.getDataType()), new RecordField("score", RecordFieldType.LONG.getDataType()))); Map<String, Object> values = new HashMap<>(); values.put("id", id); values.put("name", name); values.put("age", age); + values.put("updated_at", System.currentTimeMillis() * 1000); values.put("score", 10000L); new PutKudu().buildPartialRow( kuduSchema,
