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 2016/11/07 11:51:56 UTC
[3/5] incubator-carbondata git commit: Pass block size to model
during compaction.
Pass block size to model during compaction.
Project: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/commit/ad9a5155
Tree: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/tree/ad9a5155
Diff: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/diff/ad9a5155
Branch: refs/heads/branch-0.2
Commit: ad9a5155e1734177ddbad1d5265b3db887c0404a
Parents: 91d94e7
Author: Ashok <as...@gmail.com>
Authored: Thu Nov 3 07:35:37 2016 +0530
Committer: ravipesala <ra...@gmail.com>
Committed: Mon Nov 7 17:12:36 2016 +0530
----------------------------------------------------------------------
.../carbondata/integration/spark/merger/RowResultMerger.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-carbondata/blob/ad9a5155/integration/spark/src/main/java/org/apache/carbondata/integration/spark/merger/RowResultMerger.java
----------------------------------------------------------------------
diff --git a/integration/spark/src/main/java/org/apache/carbondata/integration/spark/merger/RowResultMerger.java b/integration/spark/src/main/java/org/apache/carbondata/integration/spark/merger/RowResultMerger.java
index be2a81d..7c3d2a7 100644
--- a/integration/spark/src/main/java/org/apache/carbondata/integration/spark/merger/RowResultMerger.java
+++ b/integration/spark/src/main/java/org/apache/carbondata/integration/spark/merger/RowResultMerger.java
@@ -102,7 +102,8 @@ public class RowResultMerger {
this.tableName = tableName;
this.measureCount = segprop.getMeasures().size();
-
+ CarbonTable carbonTable = CarbonMetadata.getInstance()
+ .getCarbonTable(databaseName + CarbonCommonConstants.UNDERSCORE + tableName);
CarbonFactDataHandlerModel carbonFactDataHandlerModel =
getCarbonFactDataHandlerModel(loadModel);
carbonFactDataHandlerModel.setPrimitiveDimLens(segprop.getDimColumnsCardinality());
@@ -117,7 +118,7 @@ public class RowResultMerger {
carbonFactDataHandlerModel.setMdKeyIndex(measureCount);
}
carbonFactDataHandlerModel.setColCardinality(colCardinality);
-
+ carbonFactDataHandlerModel.setBlockSizeInMB(carbonTable.getBlockSizeInMB());
dataHandler = new CarbonFactDataHandlerColumnar(carbonFactDataHandlerModel);
tupleConvertor = new TupleConversionAdapter(segProp);