You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@carbondata.apache.org by ra...@apache.org on 2019/07/15 11:35:33 UTC
[carbondata] branch master updated: [HOTFIX] Fixed MinMax Based
Pruning for Measure column in case of Legacy store
This is an automated email from the ASF dual-hosted git repository.
ravipesala pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/carbondata.git
The following commit(s) were added to refs/heads/master by this push:
new b017253 [HOTFIX] Fixed MinMax Based Pruning for Measure column in case of Legacy store
b017253 is described below
commit b017253f4eb0fb78e8249e895a8a2a4d2ab929da
Author: Indhumathi27 <in...@gmail.com>
AuthorDate: Tue Jul 9 14:01:07 2019 +0530
[HOTFIX] Fixed MinMax Based Pruning for Measure column in case of Legacy store
This closes #3320
---
.../core/scan/filter/executer/IncludeFilterExecuterImpl.java | 9 ++++++---
1 file changed, 6 insertions(+), 3 deletions(-)
diff --git a/core/src/main/java/org/apache/carbondata/core/scan/filter/executer/IncludeFilterExecuterImpl.java b/core/src/main/java/org/apache/carbondata/core/scan/filter/executer/IncludeFilterExecuterImpl.java
index 1231aa0..bfa2460 100644
--- a/core/src/main/java/org/apache/carbondata/core/scan/filter/executer/IncludeFilterExecuterImpl.java
+++ b/core/src/main/java/org/apache/carbondata/core/scan/filter/executer/IncludeFilterExecuterImpl.java
@@ -509,9 +509,12 @@ public class IncludeFilterExecuterImpl implements FilterExecuter {
}
} else if (isMeasurePresentInCurrentBlock) {
chunkIndex = msrColumnEvaluatorInfo.getColumnIndexInMinMaxByteArray();
- isScanRequired = isScanRequired(blkMaxVal[chunkIndex], blkMinVal[chunkIndex],
- msrColumnExecutorInfo.getFilterKeys(),
- msrColumnEvaluatorInfo.getType());
+ if (isMinMaxSet[chunkIndex]) {
+ isScanRequired = isScanRequired(blkMaxVal[chunkIndex], blkMinVal[chunkIndex],
+ msrColumnExecutorInfo.getFilterKeys(), msrColumnEvaluatorInfo.getType());
+ } else {
+ isScanRequired = true;
+ }
}
if (isScanRequired) {