nifi-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bbe...@apache.org
Subject nifi git commit: NIFI-2622: Added support for complex types in SelectHiveQL
Date Tue, 23 Aug 2016 19:52:46 GMT
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 <bbende@apache.org>


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 <mattyb149@apache.org>
Authored: Tue Aug 23 11:54:09 2016 -0400
Committer: Bryan Bende <bbende@apache.org>
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;
 


Mime
View raw message