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 <[email protected]>
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
}