You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by ni...@apache.org on 2019/06/25 06:00:50 UTC
[kylin] 02/02: KYLIN-4024 Support pushdown to presto
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 <hi...@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);
}