carbondata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ravipes...@apache.org
Subject [04/50] carbondata git commit: [CARBONDATA-2753] Fix Compatibility issue with Preaggregate table
Date Mon, 30 Jul 2018 18:42:30 GMT
[CARBONDATA-2753] Fix Compatibility issue with Preaggregate table

Problem: User creates maintable and load data and create preaggregate datamap on maintable
using old version
and loads data into maintable using new version and dataload fails.

This closes #2523


Project: http://git-wip-us.apache.org/repos/asf/carbondata/repo
Commit: http://git-wip-us.apache.org/repos/asf/carbondata/commit/99021f60
Tree: http://git-wip-us.apache.org/repos/asf/carbondata/tree/99021f60
Diff: http://git-wip-us.apache.org/repos/asf/carbondata/diff/99021f60

Branch: refs/heads/branch-1.4
Commit: 99021f604df5f7f30464095493097ee519a08ad0
Parents: ffcd635
Author: Indhumathi27 <indhumathim27@gmail.com>
Authored: Wed Jul 18 20:47:06 2018 +0530
Committer: ravipesala <ravi.pesala@gmail.com>
Committed: Tue Jul 31 00:10:41 2018 +0530

----------------------------------------------------------------------
 .../core/metadata/schema/table/DataMapSchemaFactory.java       | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/carbondata/blob/99021f60/core/src/main/java/org/apache/carbondata/core/metadata/schema/table/DataMapSchemaFactory.java
----------------------------------------------------------------------
diff --git a/core/src/main/java/org/apache/carbondata/core/metadata/schema/table/DataMapSchemaFactory.java
b/core/src/main/java/org/apache/carbondata/core/metadata/schema/table/DataMapSchemaFactory.java
index e8022cc..99fc403 100644
--- a/core/src/main/java/org/apache/carbondata/core/metadata/schema/table/DataMapSchemaFactory.java
+++ b/core/src/main/java/org/apache/carbondata/core/metadata/schema/table/DataMapSchemaFactory.java
@@ -28,9 +28,11 @@ public class DataMapSchemaFactory {
    * @return data map schema
    */
   public DataMapSchema getDataMapSchema(String dataMapName, String providerName) {
-    if (providerName.equalsIgnoreCase(DataMapClassProvider.PREAGGREGATE.toString())) {
+    if (providerName.equalsIgnoreCase(DataMapClassProvider.PREAGGREGATE.toString()) || providerName
+        .equalsIgnoreCase(DataMapClassProvider.PREAGGREGATE.getClassName())) {
       return new AggregationDataMapSchema(dataMapName, providerName);
-    } else if (providerName.equalsIgnoreCase(DataMapClassProvider.TIMESERIES.toString()))
{
+    } else if (providerName.equalsIgnoreCase(DataMapClassProvider.TIMESERIES.toString())
+        || providerName.equalsIgnoreCase(DataMapClassProvider.TIMESERIES.getClassName()))
{
       return new AggregationDataMapSchema(dataMapName, providerName);
     } else {
       return new DataMapSchema(dataMapName, providerName);


Mime
View raw message