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/06/19 05:49:50 UTC
[3/3] carbondata git commit: [CARBONDATA-1018] Add unsafe ColumnPage
implementation. This closes #1000
[CARBONDATA-1018] Add unsafe ColumnPage implementation. This closes #1000
Project: http://git-wip-us.apache.org/repos/asf/carbondata/repo
Commit: http://git-wip-us.apache.org/repos/asf/carbondata/commit/d5e3000d
Tree: http://git-wip-us.apache.org/repos/asf/carbondata/tree/d5e3000d
Diff: http://git-wip-us.apache.org/repos/asf/carbondata/diff/d5e3000d
Branch: refs/heads/master
Commit: d5e3000d17233ffebd4879d50a1b99dd4e6e0250
Parents: 94c4910 7359601
Author: ravipesala <ra...@gmail.com>
Authored: Mon Jun 19 11:19:11 2017 +0530
Committer: ravipesala <ra...@gmail.com>
Committed: Mon Jun 19 11:19:11 2017 +0530
----------------------------------------------------------------------
.../core/constants/CarbonCommonConstants.java | 10 +
.../chunk/impl/MeasureRawColumnChunk.java | 3 +-
.../chunk/reader/MeasureColumnChunkReader.java | 3 +-
.../AbstractMeasureChunkReaderV2V3Format.java | 3 +-
...CompressedMeasureChunkFileBasedReaderV1.java | 3 +-
...CompressedMeasureChunkFileBasedReaderV2.java | 3 +-
...CompressedMeasureChunkFileBasedReaderV3.java | 7 +-
.../core/datastore/page/ColumnPage.java | 496 ++++++-------
.../core/datastore/page/LazyColumnPage.java | 7 +-
.../datastore/page/SafeFixLengthColumnPage.java | 310 ++++++++
.../datastore/page/SafeVarLengthColumnPage.java | 71 ++
.../page/UnsafeFixLengthColumnPage.java | 334 +++++++++
.../page/UnsafeVarLengthColumnPage.java | 128 ++++
.../datastore/page/VarLengthColumnPageBase.java | 247 +++++++
.../page/encoding/AdaptiveCompressionCodec.java | 5 +-
.../page/encoding/AdaptiveIntegerCodec.java | 9 +-
.../page/encoding/ColumnPageCodec.java | 5 +-
.../page/encoding/CompressionCodec.java | 5 +-
.../page/encoding/DeltaIntegerCodec.java | 9 +-
.../encoding/UpscaleDeltaFloatingCodec.java | 9 +-
.../page/encoding/UpscaleFloatingCodec.java | 9 +-
.../page/statistics/ColumnPageStatsVO.java | 15 +-
.../core/memory/IntPointerBuffer.java | 16 +-
.../core/memory/UnsafeMemoryManager.java | 27 +-
.../core/metadata/datatype/DataType.java | 3 +
.../executer/RowLevelFilterExecuterImpl.java | 31 +-
.../core/scan/result/AbstractScannedResult.java | 30 +-
.../result/impl/FilterQueryScannedResult.java | 4 +-
.../core/scan/scanner/impl/FilterScanner.java | 3 +-
.../apache/carbondata/core/util/ByteUtil.java | 12 +
.../examples/CarbonSessionExample.scala | 2 +-
.../carbondata/examples/CompareTest.scala | 4 +-
.../TestNullAndEmptyFieldsUnsafe.scala | 119 ++++
.../TestLoadDataWithHiveSyntaxUnsafe.scala | 709 +++++++++++++++++++
.../carbondata/CarbonDataSourceSuite.scala | 2 +-
.../store/CarbonFactDataHandlerColumnar.java | 10 +-
.../carbondata/processing/store/TablePage.java | 39 +-
.../processing/store/TablePageEncoder.java | 6 +-
.../writer/v3/CarbonFactDataWriterImplV3.java | 2 +
39 files changed, 2333 insertions(+), 377 deletions(-)
----------------------------------------------------------------------