Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1377#discussion_r141528126
--- Diff:
core/src/main/java/org/apache/carbondata/core/datamap/DataMapStoreManager.java
---
@@ -151,4 +158,61 @@ public static DataMapStoreManager getInstance() {
return instance;
}
+ public TableSegmentRefresher
getTableSegmentRefresher(AbsoluteTableIdentifier identifier) {
+ String uniqueName = identifier.uniqueName();
+ if (segmentRefreshMap.get(uniqueName) == null) {
+ segmentRefreshMap.put(uniqueName, new
TableSegmentRefresher(identifier));
+ }
+ return segmentRefreshMap.get(uniqueName);
+ }
+
+ /**
+ * Keep track of the segment refresh time.
+ */
+ public static class TableSegmentRefresher {
+
+ private Map<String, Long> segmentRefreshTime = new HashMap<>();
--- End diff --
ok
---
