carbondata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ravipes...@apache.org
Subject [1/2] incubator-carbondata git commit: Fixed data mismatch issue after compaction
Date Thu, 08 Sep 2016 04:18:10 GMT
Repository: incubator-carbondata
Updated Branches:
  refs/heads/master c3597743d -> 69a2fe6df


Fixed data mismatch issue after 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/d56580d5
Tree: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/tree/d56580d5
Diff: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/diff/d56580d5

Branch: refs/heads/master
Commit: d56580d565002f86c0f2d0a39fb4a25f9871b20b
Parents: c359774
Author: kumarvishal <kumarvishal.1802@gmail.com>
Authored: Wed Sep 7 12:48:19 2016 +0530
Committer: ravipesala <ravi.pesala@gmail.com>
Committed: Thu Sep 8 09:43:55 2016 +0530

----------------------------------------------------------------------
 .../integration/spark/merger/RowResultMerger.java           | 9 +++++++++
 1 file changed, 9 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-carbondata/blob/d56580d5/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 6b484b6..3e805fa 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
@@ -34,6 +34,7 @@ import org.apache.carbondata.core.carbon.CarbonTableIdentifier;
 import org.apache.carbondata.core.carbon.datastore.block.SegmentProperties;
 import org.apache.carbondata.core.carbon.metadata.CarbonMetadata;
 import org.apache.carbondata.core.carbon.metadata.schema.table.CarbonTable;
+import org.apache.carbondata.core.carbon.metadata.schema.table.column.CarbonDimension;
 import org.apache.carbondata.core.carbon.metadata.schema.table.column.CarbonMeasure;
 import org.apache.carbondata.core.carbon.metadata.schema.table.column.ColumnSchema;
 import org.apache.carbondata.core.carbon.path.CarbonStorePath;
@@ -250,6 +251,14 @@ public class RowResultMerger {
             loadModel.getPartitionId(), loadModel.getSegmentId());
     carbonFactDataHandlerModel.setCarbonDataDirectoryPath(carbonDataDirectoryPath);
 
+    List<CarbonDimension> dimensionByTableName =
+        loadModel.getCarbonDataLoadSchema().getCarbonTable().getDimensionByTableName(tableName);
+    boolean[] isUseInvertedIndexes = new boolean[dimensionByTableName.size()];
+    int index = 0;
+    for (CarbonDimension dimension : dimensionByTableName) {
+      isUseInvertedIndexes[index++] = dimension.isUseInvertedIndnex();
+    }
+    carbonFactDataHandlerModel.setIsUseInvertedIndex(isUseInvertedIndexes);
     return carbonFactDataHandlerModel;
   }
 


Mime
View raw message