carbondata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ravipes...@apache.org
Subject [1/3] carbondata git commit: Fixed Synchronization issue and improve IUD performance
Date Mon, 12 Jun 2017 15:39:18 GMT
Repository: carbondata
Updated Branches:
  refs/heads/master fe7ef52c4 -> c09afce02


http://git-wip-us.apache.org/repos/asf/carbondata/blob/8a5ed819/processing/src/test/java/org/apache/carbondata/carbon/datastore/BlockIndexStoreTest.java
----------------------------------------------------------------------
diff --git a/processing/src/test/java/org/apache/carbondata/carbon/datastore/BlockIndexStoreTest.java
b/processing/src/test/java/org/apache/carbondata/carbon/datastore/BlockIndexStoreTest.java
index 23f7230..d5a4f02 100644
--- a/processing/src/test/java/org/apache/carbondata/carbon/datastore/BlockIndexStoreTest.java
+++ b/processing/src/test/java/org/apache/carbondata/carbon/datastore/BlockIndexStoreTest.java
@@ -81,7 +81,7 @@ public class BlockIndexStoreTest extends TestCase {
     File file = getPartFile();
     TableBlockInfo info =
         new TableBlockInfo(file.getAbsolutePath(), 0, "0", new String[] { "loclhost" },
-            file.length(), ColumnarFormatVersion.V1);
+            file.length(), ColumnarFormatVersion.V1, null);
     CarbonTableIdentifier carbonTableIdentifier =
             new CarbonTableIdentifier(CarbonCommonConstants.DATABASE_DEFAULT_NAME, "t3",
"1");
     AbsoluteTableIdentifier absoluteTableIdentifier =
@@ -116,20 +116,20 @@ public class BlockIndexStoreTest extends TestCase {
     File file = getPartFile();
     TableBlockInfo info =
         new TableBlockInfo(file.getAbsolutePath(), 0, "0", new String[] { "loclhost" },
-            file.length(), ColumnarFormatVersion.V1);
+            file.length(), ColumnarFormatVersion.V1, null);
     TableBlockInfo info1 =
         new TableBlockInfo(file.getAbsolutePath(), 0, "0", new String[] { "loclhost" },
-            file.length(), ColumnarFormatVersion.V1);
+            file.length(), ColumnarFormatVersion.V1, null);
 
     TableBlockInfo info2 =
         new TableBlockInfo(file.getAbsolutePath(), 0, "1", new String[] { "loclhost" },
-            file.length(), ColumnarFormatVersion.V1);
+            file.length(), ColumnarFormatVersion.V1, null);
     TableBlockInfo info3 =
         new TableBlockInfo(file.getAbsolutePath(), 0, "1", new String[] { "loclhost" },
-            file.length(), ColumnarFormatVersion.V1);
+            file.length(), ColumnarFormatVersion.V1, null);
     TableBlockInfo info4 =
         new TableBlockInfo(file.getAbsolutePath(), 0, "1", new String[] { "loclhost" },
-            file.length(), ColumnarFormatVersion.V1);
+            file.length(), ColumnarFormatVersion.V1, null);
 
     CarbonTableIdentifier carbonTableIdentifier =
             new CarbonTableIdentifier(CarbonCommonConstants.DATABASE_DEFAULT_NAME, "t3",
"1");
@@ -176,31 +176,31 @@ public class BlockIndexStoreTest extends TestCase {
     File file = getPartFile();
     TableBlockInfo info =
         new TableBlockInfo(file.getAbsolutePath(), 0, "0", new String[] { "loclhost" },
-            file.length(), ColumnarFormatVersion.V1);
+            file.length(), ColumnarFormatVersion.V1, null);
     TableBlockInfo info1 =
         new TableBlockInfo(file.getAbsolutePath(), 0, "0", new String[] { "loclhost" },
-            file.length(), ColumnarFormatVersion.V1);
+            file.length(), ColumnarFormatVersion.V1, null);
 
     TableBlockInfo info2 =
         new TableBlockInfo(file.getAbsolutePath(), 0, "1", new String[] { "loclhost" },
-            file.length(), ColumnarFormatVersion.V1);
+            file.length(), ColumnarFormatVersion.V1, null);
     TableBlockInfo info3 =
         new TableBlockInfo(file.getAbsolutePath(), 0, "1", new String[] { "loclhost" },
-            file.length(), ColumnarFormatVersion.V1);
+            file.length(), ColumnarFormatVersion.V1, null);
     TableBlockInfo info4 =
         new TableBlockInfo(file.getAbsolutePath(), 0, "1", new String[] { "loclhost" },
-            file.length(), ColumnarFormatVersion.V1);
+            file.length(), ColumnarFormatVersion.V1, null);
 
     TableBlockInfo info5 =
         new TableBlockInfo(file.getAbsolutePath(), 0, "2", new String[] { "loclhost" },
-            file.length(),ColumnarFormatVersion.V1);
+            file.length(),ColumnarFormatVersion.V1, null);
     TableBlockInfo info6 =
         new TableBlockInfo(file.getAbsolutePath(), 0, "2", new String[] { "loclhost" },
-            file.length(), ColumnarFormatVersion.V1);
+            file.length(), ColumnarFormatVersion.V1, null);
 
     TableBlockInfo info7 =
         new TableBlockInfo(file.getAbsolutePath(), 0, "3", new String[] { "loclhost" },
-            file.length(), ColumnarFormatVersion.V1);
+            file.length(), ColumnarFormatVersion.V1, null);
 
     CarbonTableIdentifier carbonTableIdentifier =
             new CarbonTableIdentifier(CarbonCommonConstants.DATABASE_DEFAULT_NAME, "t3",
"1");


Mime
View raw message