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 2017/07/03 09:50:27 UTC
[5/5] carbondata git commit: [CARBONDATA-1257] Measure Filter
implementation. This closes #1124
[CARBONDATA-1257] Measure Filter implementation. This closes #1124
Project: http://git-wip-us.apache.org/repos/asf/carbondata/repo
Commit: http://git-wip-us.apache.org/repos/asf/carbondata/commit/c013d42a
Tree: http://git-wip-us.apache.org/repos/asf/carbondata/tree/c013d42a
Diff: http://git-wip-us.apache.org/repos/asf/carbondata/diff/c013d42a
Branch: refs/heads/branch-1.1
Commit: c013d42a12bfa352a2604e8bb7f523f9813fbad1
Parents: d4adc09 f274bf4
Author: ravipesala <ra...@gmail.com>
Authored: Mon Jul 3 15:19:49 2017 +0530
Committer: ravipesala <ra...@gmail.com>
Committed: Mon Jul 3 15:19:49 2017 +0530
----------------------------------------------------------------------
.../core/datastore/block/SegmentProperties.java | 7 +
.../schema/table/column/CarbonColumn.java | 7 +
.../core/scan/expression/ColumnExpression.java | 21 ++
.../conditional/ConditionalExpression.java | 2 +-
.../logical/BinaryLogicalExpression.java | 4 +-
.../core/scan/filter/ColumnFilterInfo.java | 88 ++++++
.../core/scan/filter/DimColumnFilterInfo.java | 78 -----
.../scan/filter/FilterExpressionProcessor.java | 70 ++++-
.../carbondata/core/scan/filter/FilterUtil.java | 289 +++++++++++++++----
.../ExcludeColGroupFilterExecuterImpl.java | 2 +-
.../executer/ExcludeFilterExecuterImpl.java | 155 ++++++++--
.../IncludeColGroupFilterExecuterImpl.java | 2 +-
.../executer/IncludeFilterExecuterImpl.java | 214 +++++++++++---
.../MeasureColumnExecuterFilterInfo.java | 30 ++
.../executer/RestructureEvaluatorImpl.java | 40 ++-
.../RestructureExcludeFilterExecutorImpl.java | 17 +-
.../RestructureIncludeFilterExecutorImpl.java | 17 +-
.../executer/RowLevelFilterExecuterImpl.java | 24 +-
.../RowLevelRangeGrtThanFiterExecuterImpl.java | 219 +++++++++++---
...elRangeGrtrThanEquaToFilterExecuterImpl.java | 220 +++++++++++---
...velRangeLessThanEqualFilterExecuterImpl.java | 187 +++++++++---
.../RowLevelRangeLessThanFiterExecuterImpl.java | 190 +++++++++---
.../RowLevelRangeTypeExecuterFacory.java | 25 +-
.../resolver/ConditionalFilterResolverImpl.java | 103 +++++--
.../filter/resolver/FilterResolverIntf.java | 9 +
.../resolver/LogicalFilterResolverImpl.java | 4 +
.../resolver/RowLevelFilterResolverImpl.java | 3 +-
.../RowLevelRangeFilterResolverImpl.java | 93 ++++--
.../resolverinfo/ColumnResolvedFilterInfo.java | 22 ++
.../DimColumnResolvedFilterInfo.java | 22 +-
.../MeasureColumnResolvedFilterInfo.java | 98 ++++++-
.../TrueConditionalResolverImpl.java | 2 +-
.../visitor/CustomTypeDictionaryVisitor.java | 17 +-
.../visitor/DictionaryColumnVisitor.java | 11 +-
.../visitor/FilterInfoTypeVisitorFactory.java | 16 +-
.../visitor/MeasureColumnVisitor.java | 77 +++++
.../visitor/NoDictionaryTypeVisitor.java | 10 +-
.../visitor/RangeDictionaryColumnVisitor.java | 10 +-
.../visitor/RangeDirectDictionaryVisitor.java | 10 +-
.../visitor/RangeNoDictionaryTypeVisitor.java | 10 +-
.../visitor/ResolvedFilterInfoVisitorIntf.java | 5 +-
.../carbondata/core/scan/model/QueryModel.java | 18 +-
.../apache/carbondata/core/util/CarbonUtil.java | 8 +
.../carbondata/core/util/DataTypeUtil.java | 69 +++++
.../core/scan/filter/FilterUtilTest.java | 9 +-
.../ExpressionWithNullTestCase.scala | 10 +-
.../spark/sql/SparkUnknownExpression.scala | 2 +-
.../spark/sql/SparkUnknownExpression.scala | 2 +-
.../vectorreader/AddColumnTestCases.scala | 4 +-
.../store/CarbonFactDataHandlerColumnar.java | 4 +
.../writer/v3/CarbonFactDataWriterImplV3.java | 14 +
51 files changed, 2038 insertions(+), 532 deletions(-)
----------------------------------------------------------------------