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

xxyu pushed a commit to branch kylin-on-parquet-v2
in repository https://gitbox.apache.org/repos/asf/kylin.git


The following commit(s) were added to refs/heads/kylin-on-parquet-v2 by this 
push:
     new 0cf9e3d  KYLIN-4887 Segment pruner support string type partition col 
in spark query engine
0cf9e3d is described below

commit 0cf9e3d5951e880f04033efa599059237deba766
Author: zhengshengjun <shengjun_zh...@sina.com>
AuthorDate: Wed Jan 27 17:12:57 2021 +0800

    KYLIN-4887 Segment pruner support string type partition col in spark query 
engine
---
 .../scala/org/apache/spark/sql/execution/datasource/FilePruner.scala | 5 +----
 1 file changed, 1 insertion(+), 4 deletions(-)

diff --git 
a/kylin-spark-project/kylin-spark-common/src/main/scala/org/apache/spark/sql/execution/datasource/FilePruner.scala
 
b/kylin-spark-project/kylin-spark-common/src/main/scala/org/apache/spark/sql/execution/datasource/FilePruner.scala
index 0910d86..9f62f52 100644
--- 
a/kylin-spark-project/kylin-spark-common/src/main/scala/org/apache/spark/sql/execution/datasource/FilePruner.scala
+++ 
b/kylin-spark-project/kylin-spark-common/src/main/scala/org/apache/spark/sql/execution/datasource/FilePruner.scala
@@ -132,11 +132,8 @@ class FilePruner(
         // we can only get col ID in layout cuz data schema is all ids.
         val id = layoutEntity.getOrderedDimensions.asScala.values.find(column 
=> column.columnName.equals(ref.getName))
         if (id.isDefined && (ref.getType.isDateTimeFamily || 
ref.getType.isStringFamily)) {
-          if (ref.getType.isDateTimeFamily) {
-            pattern = desc.getPartitionDateFormat
-          }
+          pattern = desc.getPartitionDateFormat
           dataSchema.filter(_.name == String.valueOf(id.get.id))
-
         } else {
           Seq.empty
         }

Reply via email to