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 2018/10/09 15:50:16 UTC
[14/45] carbondata git commit: [CARBONDATA-2972] Debug Logs and
function added for Adaptive Encoding
[CARBONDATA-2972] Debug Logs and function added for Adaptive Encoding
Added a function to get the type of encoding used. Added the debug log for checking which type of encoding is used
This closes #2758
Project: http://git-wip-us.apache.org/repos/asf/carbondata/repo
Commit: http://git-wip-us.apache.org/repos/asf/carbondata/commit/54bcf496
Tree: http://git-wip-us.apache.org/repos/asf/carbondata/tree/54bcf496
Diff: http://git-wip-us.apache.org/repos/asf/carbondata/diff/54bcf496
Branch: refs/heads/branch-1.5
Commit: 54bcf49638262af82583d930632018da6c73c8c5
Parents: 1b4109d
Author: Manish Nalla <ma...@gmail.com>
Authored: Tue Sep 25 17:44:49 2018 +0530
Committer: manishgupta88 <to...@gmail.com>
Committed: Thu Sep 27 17:16:37 2018 +0530
----------------------------------------------------------------------
.../core/datastore/page/encoding/ColumnPageEncoder.java | 8 ++++++++
.../org/apache/carbondata/processing/store/TablePage.java | 3 ++-
2 files changed, 10 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/carbondata/blob/54bcf496/core/src/main/java/org/apache/carbondata/core/datastore/page/encoding/ColumnPageEncoder.java
----------------------------------------------------------------------
diff --git a/core/src/main/java/org/apache/carbondata/core/datastore/page/encoding/ColumnPageEncoder.java b/core/src/main/java/org/apache/carbondata/core/datastore/page/encoding/ColumnPageEncoder.java
index 3067823..44e7192 100644
--- a/core/src/main/java/org/apache/carbondata/core/datastore/page/encoding/ColumnPageEncoder.java
+++ b/core/src/main/java/org/apache/carbondata/core/datastore/page/encoding/ColumnPageEncoder.java
@@ -78,6 +78,14 @@ public abstract class ColumnPageEncoder {
}
}
+ public Encoding getEncodingType() {
+ List<Encoding> currEncodingList = getEncodingList();
+ if (CarbonUtil.isEncodedWithMeta(currEncodingList)) {
+ return currEncodingList.get(0);
+ }
+ return null;
+ }
+
/**
* Return a encoded column page by encoding the input page
* The encoded binary data and metadata are wrapped in encoding column page
http://git-wip-us.apache.org/repos/asf/carbondata/blob/54bcf496/processing/src/main/java/org/apache/carbondata/processing/store/TablePage.java
----------------------------------------------------------------------
diff --git a/processing/src/main/java/org/apache/carbondata/processing/store/TablePage.java b/processing/src/main/java/org/apache/carbondata/processing/store/TablePage.java
index 791b4c6..82129db 100644
--- a/processing/src/main/java/org/apache/carbondata/processing/store/TablePage.java
+++ b/processing/src/main/java/org/apache/carbondata/processing/store/TablePage.java
@@ -424,7 +424,8 @@ public class TablePage {
"Encoder result ---> Source data type: " + noDictDimensionPages[noDictIndex]
.getDataType().getName() + " Destination data type: " + targetDataType
.getName() + " for the column: " + noDictDimensionPages[noDictIndex]
- .getColumnSpec().getFieldName());
+ .getColumnSpec().getFieldName() + " having encoding type: "
+ + columnPageEncoder.getEncodingType());
}
}
noDictIndex++;