aboutsummaryrefslogtreecommitdiff
path: root/exec/java-exec/src/main/java/org/apache/drill/exec/store/dfs/MetadataContext.java
diff options
context:
space:
mode:
Diffstat (limited to 'exec/java-exec/src/main/java/org/apache/drill/exec/store/dfs/MetadataContext.java')
-rw-r--r--exec/java-exec/src/main/java/org/apache/drill/exec/store/dfs/MetadataContext.java7
1 files changed, 4 insertions, 3 deletions
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/store/dfs/MetadataContext.java b/exec/java-exec/src/main/java/org/apache/drill/exec/store/dfs/MetadataContext.java
index 877ceb64c..073847812 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/store/dfs/MetadataContext.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/store/dfs/MetadataContext.java
@@ -20,6 +20,7 @@ package org.apache.drill.exec.store.dfs;
import java.util.Map;
import org.apache.drill.shaded.guava.com.google.common.collect.Maps;
+import org.apache.hadoop.fs.Path;
/**
* A metadata context that holds state across multiple invocations of
@@ -32,17 +33,17 @@ public class MetadataContext {
* Note: the #directories is typically a small percentage of the #files, so the memory footprint
* is expected to be relatively small.
*/
- private Map<String, Boolean> dirModifCheckMap = Maps.newHashMap();
+ private Map<Path, Boolean> dirModifCheckMap = Maps.newHashMap();
private PruneStatus pruneStatus = PruneStatus.NOT_STARTED;
private boolean metadataCacheCorrupted;
- public void setStatus(String dir) {
+ public void setStatus(Path dir) {
dirModifCheckMap.put(dir, true);
}
- public void clearStatus(String dir) {
+ public void clearStatus(Path dir) {
dirModifCheckMap.put(dir, false);
}