Repository: nifi Updated Branches: refs/heads/master 0303805c0 -> 5d1a4f343
NIFI-2622: Added support for complex types in SelectHiveQL This closes #922. Signed-off-by: Bryan Bende <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/5d1a4f34 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/5d1a4f34 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/5d1a4f34 Branch: refs/heads/master Commit: 5d1a4f343f11606af5f45d1db4d58ca31a59e524 Parents: 0303805 Author: Matt Burgess <[email protected]> Authored: Tue Aug 23 11:54:09 2016 -0400 Committer: Bryan Bende <[email protected]> Committed: Tue Aug 23 15:52:16 2016 -0400 ---------------------------------------------------------------------- .../src/main/java/org/apache/nifi/util/hive/HiveJdbcCommon.java | 4 ++++ 1 file changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/5d1a4f34/nifi-nar-bundles/nifi-hive-bundle/nifi-hive-processors/src/main/java/org/apache/nifi/util/hive/HiveJdbcCommon.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-hive-bundle/nifi-hive-processors/src/main/java/org/apache/nifi/util/hive/HiveJdbcCommon.java b/nifi-nar-bundles/nifi-hive-bundle/nifi-hive-processors/src/main/java/org/apache/nifi/util/hive/HiveJdbcCommon.java index afb8104..d4b2945 100644 --- a/nifi-nar-bundles/nifi-hive-bundle/nifi-hive-processors/src/main/java/org/apache/nifi/util/hive/HiveJdbcCommon.java +++ b/nifi-nar-bundles/nifi-hive-bundle/nifi-hive-processors/src/main/java/org/apache/nifi/util/hive/HiveJdbcCommon.java @@ -55,6 +55,7 @@ import static java.sql.Types.DECIMAL; import static java.sql.Types.DOUBLE; import static java.sql.Types.FLOAT; import static java.sql.Types.INTEGER; +import static java.sql.Types.JAVA_OBJECT; import static java.sql.Types.LONGNVARCHAR; import static java.sql.Types.LONGVARBINARY; import static java.sql.Types.LONGVARCHAR; @@ -64,6 +65,7 @@ import static java.sql.Types.NVARCHAR; import static java.sql.Types.REAL; import static java.sql.Types.ROWID; import static java.sql.Types.SMALLINT; +import static java.sql.Types.STRUCT; import static java.sql.Types.TIME; import static java.sql.Types.TIMESTAMP; import static java.sql.Types.TINYINT; @@ -211,6 +213,8 @@ public class HiveJdbcCommon { case NVARCHAR: case VARCHAR: case ARRAY: + case STRUCT: + case JAVA_OBJECT: builder.name(columnName).type().unionOf().nullBuilder().endNull().and().stringType().endUnion().noDefault(); break;
