[CARBONDATA-495] Unify compressor interface This closes #401
Project: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/commit/b7f3be7e Tree: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/tree/b7f3be7e Diff: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/diff/b7f3be7e Branch: refs/heads/master Commit: b7f3be7e03f7f619143b7ec17e748333d9771d6e Parents: 7277355 25b4ba2 Author: jackylk <jacky.li...@huawei.com> Authored: Tue Dec 6 12:03:53 2016 +0800 Committer: jackylk <jacky.li...@huawei.com> Committed: Tue Dec 6 12:03:53 2016 +0800 ---------------------------------------------------------------------- .../reader/dimension/AbstractChunkReader.java | 5 +- ...mpressedDimensionChunkFileBasedReaderV1.java | 2 +- ...mpressedDimensionChunkFileBasedReaderV2.java | 5 +- ...CompressedMeasureChunkFileBasedReaderV1.java | 4 +- ...CompressedMeasureChunkFileBasedReaderV2.java | 7 +- .../core/constants/CarbonCommonConstants.java | 11 + .../store/compression/Compressor.java | 26 +- .../store/compression/CompressorFactory.java | 42 +++ .../store/compression/SnappyCompression.java | 273 ------------------- .../store/compression/SnappyCompressor.java | 153 +++++++++++ .../compression/ValueCompressonHolder.java | 43 +-- .../compression/type/UnCompressByteArray.java | 12 +- .../compression/type/UnCompressMaxMinByte.java | 10 +- .../type/UnCompressMaxMinByteForLong.java | 8 +- .../type/UnCompressMaxMinDefault.java | 9 +- .../type/UnCompressMaxMinDefaultLong.java | 7 +- .../compression/type/UnCompressMaxMinFloat.java | 11 +- .../compression/type/UnCompressMaxMinInt.java | 8 +- .../compression/type/UnCompressMaxMinLong.java | 9 +- .../compression/type/UnCompressMaxMinShort.java | 8 +- .../type/UnCompressNonDecimalByte.java | 9 +- .../type/UnCompressNonDecimalDefault.java | 7 +- .../type/UnCompressNonDecimalFloat.java | 7 +- .../type/UnCompressNonDecimalInt.java | 9 +- .../type/UnCompressNonDecimalLong.java | 10 +- .../type/UnCompressNonDecimalMaxMinByte.java | 9 +- .../type/UnCompressNonDecimalMaxMinDefault.java | 10 +- .../type/UnCompressNonDecimalMaxMinFloat.java | 7 +- .../type/UnCompressNonDecimalMaxMinInt.java | 9 +- .../type/UnCompressNonDecimalMaxMinLong.java | 7 +- .../type/UnCompressNonDecimalMaxMinShort.java | 9 +- .../type/UnCompressNonDecimalShort.java | 7 +- .../compression/type/UnCompressNoneByte.java | 7 +- .../compression/type/UnCompressNoneDefault.java | 8 +- .../compression/type/UnCompressNoneFloat.java | 13 +- .../compression/type/UnCompressNoneInt.java | 31 ++- .../compression/type/UnCompressNoneLong.java | 9 +- .../compression/type/UnCompressNoneShort.java | 13 +- .../store/dataholder/CarbonReadDataHolder.java | 84 ++---- ...HeavyCompressedDoubleArrayDataFileStore.java | 110 -------- .../uncompressed/DoubleArrayDataFileStore.java | 86 ------ .../DoubleArrayDataInMemoryStore.java | 5 - .../key/columnar/AbstractColumnarKeyStore.java | 106 ------- .../CompressedColumnarFileKeyStore.java | 168 ------------ .../CompressedColumnarInMemoryStore.java | 155 ----------- .../CompressedColumnarKeyStoreUtil.java | 108 -------- .../UnCompressedColumnarFileKeyStore.java | 88 ------ .../UnCompressedColumnarInMemoryStore.java | 70 ----- .../AbstractCompressedSingleArrayStore.java | 119 -------- .../CompressedSingleArrayKeyFileStore.java | 92 ------- .../CompressedSingleArrayKeyInMemoryStore.java | 46 ---- .../AbstractSingleArrayKeyStore.java | 107 -------- .../uncompressed/SingleArrayKeyFileStore.java | 104 ------- .../SingleArrayKeyInMemoryStore.java | 36 --- .../core/util/CarbonMetadataUtil.java | 6 +- ...ressedDimensionChunkFileBasedReaderTest.java | 18 +- .../sortdata/CompressedTempSortFileReader.java | 6 +- .../sortdata/CompressedTempSortFileWriter.java | 4 +- .../store/writer/AbstractFactDataWriter.java | 4 +- 59 files changed, 412 insertions(+), 1944 deletions(-) ----------------------------------------------------------------------
