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.java20
1 files changed, 20 insertions, 0 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 17852ab5e..d115bee98 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
@@ -33,6 +33,14 @@ public class MetadataContext {
*/
private Map<String, Boolean> dirModifCheckMap = Maps.newHashMap();
+ public enum PruneStatus {
+ NOT_STARTED, // initial state
+ PRUNED, // partitions were pruned
+ NOT_PRUNED // partitions did not get pruned
+ }
+
+ private PruneStatus pruneStatus = PruneStatus.NOT_STARTED;
+
public MetadataContext() {
}
@@ -55,6 +63,18 @@ public class MetadataContext {
dirModifCheckMap.clear();
}
+ public void setPruneStatus(PruneStatus status) {
+ pruneStatus = status;
+ }
+
+ public boolean wasPruningStarted() {
+ return pruneStatus != PruneStatus.NOT_STARTED;
+ }
+
+ public boolean wasPruned() {
+ return pruneStatus == PruneStatus.PRUNED;
+ }
+
}