[kylin] 02/02: KYLIN-4024 Support pushdown to presto

[nic]

This is an automated email from the ASF dual-hosted git repository.

nic pushed a commit to branch 2.6.x
in repository https://gitbox.apache.org/repos/asf/kylin.git

commit c0b69b08db52190614f9356c8614a31c76ea48c0
Author: hit-lacus <hit_la...@126.com>
AuthorDate: Sun Jun 9 18:54:12 2019 +0800

    KYLIN-4024 Support pushdown to presto
---
 .../org/apache/kylin/query/adhoc/PushDownRunnerJdbcImpl.java     | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git 
a/query/src/main/java/org/apache/kylin/query/adhoc/PushDownRunnerJdbcImpl.java 
b/query/src/main/java/org/apache/kylin/query/adhoc/PushDownRunnerJdbcImpl.java
index abdeeb3..de73327 100644
--- 
a/query/src/main/java/org/apache/kylin/query/adhoc/PushDownRunnerJdbcImpl.java
+++ 
b/query/src/main/java/org/apache/kylin/query/adhoc/PushDownRunnerJdbcImpl.java
@@ -75,7 +75,8 @@ public class PushDownRunnerJdbcImpl extends 
AbstractPushdownRunner {
         }
     }
 
-    private SelectedColumnMeta extractColumnMeta(ResultSetMetaData 
resultSetMetaData, int columnIndex) throws SQLException {
+    private SelectedColumnMeta extractColumnMeta(ResultSetMetaData 
resultSetMetaData, int columnIndex)
+            throws SQLException {
         boolean isAutoIncrement = false;
         try {
             isAutoIncrement = resultSetMetaData.isAutoIncrement(columnIndex);
@@ -256,6 +257,12 @@ public class PushDownRunnerJdbcImpl extends 
AbstractPushdownRunner {
             return Types.ARRAY;
         } else if ("struct".equalsIgnoreCase(type)) {
             return Types.STRUCT;
+        } else if ("integer".equalsIgnoreCase(type)) {
+            return Types.INTEGER;
+        } else if ("time".equalsIgnoreCase(type)) {
+            return Types.VARCHAR;
+        } else if ("varbinary".equalsIgnoreCase(type)) {
+            return Types.BINARY;
         }
         throw new SQLException("Unrecognized column type: " + type);
     }