You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@carbondata.apache.org by ja...@apache.org on 2018/09/21 07:45:18 UTC
carbondata git commit: [CARBONDATA-2955] Fix bugs in adaptive delta
integral codec with compressor
Repository: carbondata
Updated Branches:
refs/heads/master d1bfb7477 -> 817230da1
[CARBONDATA-2955] Fix bugs in adaptive delta integral codec with compressor
This closes #2741
Project: http://git-wip-us.apache.org/repos/asf/carbondata/repo
Commit: http://git-wip-us.apache.org/repos/asf/carbondata/commit/817230da
Tree: http://git-wip-us.apache.org/repos/asf/carbondata/tree/817230da
Diff: http://git-wip-us.apache.org/repos/asf/carbondata/diff/817230da
Branch: refs/heads/master
Commit: 817230da112684e057aa808711d44c305692d45f
Parents: d1bfb74
Author: xuchuanyin <xu...@hust.edu.cn>
Authored: Fri Sep 21 09:25:36 2018 +0800
Committer: Jacky Li <ja...@qq.com>
Committed: Fri Sep 21 15:45:03 2018 +0800
----------------------------------------------------------------------
.../page/encoding/adaptive/AdaptiveDeltaIntegralCodec.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/carbondata/blob/817230da/core/src/main/java/org/apache/carbondata/core/datastore/page/encoding/adaptive/AdaptiveDeltaIntegralCodec.java
----------------------------------------------------------------------
diff --git a/core/src/main/java/org/apache/carbondata/core/datastore/page/encoding/adaptive/AdaptiveDeltaIntegralCodec.java b/core/src/main/java/org/apache/carbondata/core/datastore/page/encoding/adaptive/AdaptiveDeltaIntegralCodec.java
index 9ada0bb..0e61b33 100644
--- a/core/src/main/java/org/apache/carbondata/core/datastore/page/encoding/adaptive/AdaptiveDeltaIntegralCodec.java
+++ b/core/src/main/java/org/apache/carbondata/core/datastore/page/encoding/adaptive/AdaptiveDeltaIntegralCodec.java
@@ -79,12 +79,13 @@ public class AdaptiveDeltaIntegralCodec extends AdaptiveCodec {
public ColumnPageEncoder createEncoder(Map<String, String> parameter) {
return new ColumnPageEncoder() {
byte[] result = null;
- final Compressor compressor = CompressorFactory.getInstance().getCompressor();
@Override
protected byte[] encodeData(ColumnPage input) throws MemoryException, IOException {
if (encodedPage != null) {
throw new IllegalStateException("already encoded");
}
+ Compressor compressor =
+ CompressorFactory.getInstance().getCompressor(input.getColumnCompressorName());
result = encodeAndCompressPage(input, converter, compressor);
byte[] bytes = writeInvertedIndexIfRequired(result);
encodedPage.freeMemory();