This is an automated email from the ASF dual-hosted git repository.
jackylk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/carbondata.git
The following commit(s) were added to refs/heads/master by this push:
new af843b2 [CARBONDATA-3558] Clean up codes for property
"autoRefreshDataMap"
af843b2 is described below
commit af843b2e3a46928f9a34c5aa5b73a57e4b70dccc
Author: Manhua <[email protected]>
AuthorDate: Mon Oct 28 15:21:18 2019 +0800
[CARBONDATA-3558] Clean up codes for property "autoRefreshDataMap"
Since PR #2255 support DEFERRED REBUILD when creating DataMap,
autoRefreshDataMap property is not used any more.
This closes #3422
---
.../java/org/apache/carbondata/core/datamap/DataMapProvider.java | 2 +-
.../apache/carbondata/core/metadata/schema/table/CarbonTable.java | 8 --------
.../carbondata/datamap/lucene/LuceneFineGrainDataMapSuite.scala | 6 +++---
3 files changed, 4 insertions(+), 12 deletions(-)
diff --git
a/core/src/main/java/org/apache/carbondata/core/datamap/DataMapProvider.java
b/core/src/main/java/org/apache/carbondata/core/datamap/DataMapProvider.java
index c320226..2a053ee 100644
--- a/core/src/main/java/org/apache/carbondata/core/datamap/DataMapProvider.java
+++ b/core/src/main/java/org/apache/carbondata/core/datamap/DataMapProvider.java
@@ -120,7 +120,7 @@ public abstract class DataMapProvider {
/**
* Rebuild the datamap by loading all existing data from mainTable
* This is called when refreshing the datamap when
- * 1. after datamap creation and if `autoRefreshDataMap` is set to true
+ * 1. after datamap creation and no "WITH DEFERRED REBUILD" defined
* 2. user manually trigger REBUILD DATAMAP command
*/
public boolean rebuild() throws IOException, NoSuchDataMapException {
diff --git
a/core/src/main/java/org/apache/carbondata/core/metadata/schema/table/CarbonTable.java
b/core/src/main/java/org/apache/carbondata/core/metadata/schema/table/CarbonTable.java
index f70d6fe..b36a60b 100644
---
a/core/src/main/java/org/apache/carbondata/core/metadata/schema/table/CarbonTable.java
+++
b/core/src/main/java/org/apache/carbondata/core/metadata/schema/table/CarbonTable.java
@@ -1048,14 +1048,6 @@ public class CarbonTable implements Serializable,
Writable {
}
/**
- * Return true if 'autoRefreshDataMap' is enabled, by default it is enabled
- */
- public boolean isAutoRefreshDataMap() {
- String refresh =
getTableInfo().getFactTable().getTableProperties().get("autorefreshdatamap");
- return refresh == null || refresh.equalsIgnoreCase("true");
- }
-
- /**
* whether this table has aggregation DataMap or not
*/
public boolean hasAggregationDataMap() {
diff --git
a/integration/spark-common-test/src/test/scala/org/apache/carbondata/datamap/lucene/LuceneFineGrainDataMapSuite.scala
b/integration/spark-common-test/src/test/scala/org/apache/carbondata/datamap/lucene/LuceneFineGrainDataMapSuite.scala
index d9678be..9c0ab89 100644
---
a/integration/spark-common-test/src/test/scala/org/apache/carbondata/datamap/lucene/LuceneFineGrainDataMapSuite.scala
+++
b/integration/spark-common-test/src/test/scala/org/apache/carbondata/datamap/lucene/LuceneFineGrainDataMapSuite.scala
@@ -167,7 +167,7 @@ class LuceneFineGrainDataMapSuite extends QueryTest with
BeforeAndAfterAll {
"""
| CREATE TABLE datamap_test4(id INT, name STRING, city STRING, age INT)
| STORED BY 'carbondata'
- | TBLPROPERTIES('SORT_COLUMNS'='city,name', 'SORT_SCOPE'='LOCAL_SORT',
'autorefreshdatamap' = 'false')
+ | TBLPROPERTIES('SORT_COLUMNS'='city,name', 'SORT_SCOPE'='LOCAL_SORT')
""".stripMargin)
sql(s"LOAD DATA LOCAL INPATH '$file2' INTO TABLE datamap_test4
OPTIONS('header'='false')")
@@ -829,14 +829,14 @@ class LuceneFineGrainDataMapSuite extends QueryTest with
BeforeAndAfterAll {
| CREATE TABLE datamap_test4(id INT, name STRING, city STRING, age INT)
| STORED BY 'carbondata'
| TBLPROPERTIES('SORT_COLUMNS'='city,name', 'SORT_SCOPE'='LOCAL_SORT',
- | 'autorefreshdatamap' = 'false', 'CACHE_LEVEL'='BLOCKLET')
+ | 'CACHE_LEVEL'='BLOCKLET')
""".stripMargin)
sql(
"""
| CREATE TABLE datamap_copy(id INT, name STRING, city STRING, age INT)
| STORED BY 'carbondata'
| TBLPROPERTIES('SORT_COLUMNS'='city,name', 'SORT_SCOPE'='LOCAL_SORT',
- | 'autorefreshdatamap' = 'false', 'CACHE_LEVEL'='BLOCKLET')
+ | 'CACHE_LEVEL'='BLOCKLET')
""".stripMargin)
sql("insert into datamap_test4 select 1,'name','city',20")
sql("insert into datamap_test4 select 2,'name1','city1',20")