[CARBONDATA-861] Improvements in query This closes #709
Project: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/commit/4cdb7a29 Tree: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/tree/4cdb7a29 Diff: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/diff/4cdb7a29 Branch: refs/heads/branch-1.1 Commit: 4cdb7a290a2ac5a53fdd66fab635803f281b3f35 Parents: 00535f4 8f59a32 Author: jackylk <[email protected]> Authored: Tue Apr 11 21:02:25 2017 +0800 Committer: jackylk <[email protected]> Committed: Tue Apr 11 21:02:25 2017 +0800 ---------------------------------------------------------------------- .../carbondata/core/datastore/FileHolder.java | 4 +- .../impl/VariableLengthDimensionDataChunk.java | 16 +- ...mpressedDimensionChunkFileBasedReaderV1.java | 14 +- ...mpressedDimensionChunkFileBasedReaderV2.java | 19 +-- ...mpressedDimensionChunkFileBasedReaderV3.java | 16 +- ...CompressedMeasureChunkFileBasedReaderV1.java | 16 +- ...CompressedMeasureChunkFileBasedReaderV2.java | 19 +-- ...CompressedMeasureChunkFileBasedReaderV3.java | 34 ++-- .../chunk/store/DimensionDataChunkStore.java | 9 ++ .../SafeAbsractDimensionDataChunkStore.java | 4 + ...feVariableLengthDimensionDataChunkStore.java | 36 ++++- .../UnsafeAbstractDimensionDataChunkStore.java | 4 + ...afeVariableLengthDimesionDataChunkStore.java | 12 ++ .../core/datastore/impl/DFSFileHolderImpl.java | 8 +- .../core/datastore/impl/FileHolderImpl.java | 8 +- .../DictionaryBasedVectorResultCollector.java | 1 - .../executor/impl/AbstractQueryExecutor.java | 2 +- .../core/scan/executor/util/QueryUtil.java | 2 +- .../vector/MeasureDataVectorProcessor.java | 158 +++++++++++++------ .../apache/carbondata/core/util/ByteUtil.java | 29 ++++ .../apache/carbondata/core/util/CarbonUtil.java | 12 +- .../carbondata/examples/CompareTest.scala | 4 + .../apache/carbondata/spark/CarbonOption.scala | 2 + .../VectorizedCarbonRecordReader.java | 2 +- .../spark/sql/CarbonCatalystOperators.scala | 2 +- .../spark/sql/CarbonDataFrameWriter.scala | 13 +- .../spark/sql/CarbonDictionaryDecoder.scala | 68 ++++---- .../execution/CarbonLateDecodeStrategy.scala | 5 +- 28 files changed, 328 insertions(+), 191 deletions(-) ----------------------------------------------------------------------
