diff options
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.java | 20 |
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; + } + } |