[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 <ravi.pes...@gmail.com> Authored: Mon Jul 3 15:19:49 2017 +0530 Committer: ravipesala <ravi.pes...@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(-) ----------------------------------------------------------------------