Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1489#discussion_r150414426
--- Diff:
core/src/main/java/org/apache/carbondata/core/datamap/DataMapStoreManager.java
---
@@ -144,23 +144,40 @@ private TableDataMap getTableDataMap(String
dataMapName,
* Clear the datamap/datamaps of a table from memory
* @param identifier Table identifier
*/
- public void clearDataMap(AbsoluteTableIdentifier identifier) {
+ public void clearDataMaps(AbsoluteTableIdentifier identifier) {
List<TableDataMap> tableDataMaps =
allDataMaps.get(identifier.uniqueName());
segmentRefreshMap.remove(identifier.uniqueName());
if (tableDataMaps != null) {
- int i = 0;
for (TableDataMap tableDataMap: tableDataMaps) {
if (tableDataMap != null) {
tableDataMap.clear();
break;
}
- i++;
}
allDataMaps.remove(identifier.uniqueName());
}
}
/**
+ * Clear the datamap/datamaps of a table from memory
+ * @param identifier Table identifier
+ */
+ public void clearDataMap(AbsoluteTableIdentifier identifier, String
dataMapName) {
--- End diff --
what bug?
---
