-
Notifications
You must be signed in to change notification settings - Fork 2.9k
/
DeleteOptions.java
129 lines (113 loc) · 3.52 KB
/
DeleteOptions.java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
/*
* The Alluxio Open Foundation licenses this work under the Apache License, version 2.0
* (the "License"). You may not use this work except in compliance with the License, which is
* available at www.apache.org/licenses/LICENSE-2.0
*
* This software is distributed on an "AS IS" basis, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
* either express or implied, as more fully set forth in the License.
*
* See the NOTICE file distributed with this work for information regarding copyright ownership.
*/
package alluxio.master.file.options;
import alluxio.thrift.DeleteTOptions;
import com.google.common.base.Objects;
import javax.annotation.concurrent.NotThreadSafe;
/**
* Method options for deleting a file or a directory.
*/
@NotThreadSafe
public final class DeleteOptions {
private boolean mRecursive;
private boolean mAlluxioOnly;
private boolean mUnchecked;
/**
* @return the default {@link DeleteOptions}
*/
public static DeleteOptions defaults() {
return new DeleteOptions();
}
/**
* @param options the {@link DeleteTOptions} to use
*/
public DeleteOptions(DeleteTOptions options) {
mRecursive = options.isRecursive();
mAlluxioOnly = options.isAlluxioOnly();
mUnchecked = options.isSkipConsistencyCheck();
}
private DeleteOptions() {
mRecursive = false;
mAlluxioOnly = false;
mUnchecked = false;
}
/**
* @return the recursive flag value; if the object to be deleted is a directory, the flag
* specifies whether the directory content should be recursively deleted as well
*/
public boolean isRecursive() {
return mRecursive;
}
/**
* @return return the value of the flag that indicates whether the file should be
* deleted in Alluxio only, or in UFS as well
*/
public boolean isAlluxioOnly() {
return mAlluxioOnly;
}
/**
* @return if the UFS sync check should be skipped
*/
public boolean isUnchecked() {
return mUnchecked;
}
/**
* @param recursive the recursive flag value to use; if the object to be deleted is a directory,
* the flag specifies whether the directory content should be recursively deleted as well
* @return the updated options object
*/
public DeleteOptions setRecursive(boolean recursive) {
mRecursive = recursive;
return this;
}
/**
* @param alluxioOnly the value to use for the flag that indicates whether the file should be
* deleted in Alluxio only, or in UFS as well
* @return the updated options object
*/
public DeleteOptions setAlluxioOnly(boolean alluxioOnly) {
mAlluxioOnly = alluxioOnly;
return this;
}
/**
* @param skipCheck whether to skip UFS consistency check
* @return the updated options object
*/
public DeleteOptions setUnchecked(boolean skipCheck) {
mUnchecked = skipCheck;
return this;
}
@Override
public boolean equals(Object o) {
if (this == o) {
return true;
}
if (!(o instanceof DeleteOptions)) {
return false;
}
DeleteOptions that = (DeleteOptions) o;
return Objects.equal(mRecursive, that.mRecursive)
&& Objects.equal(mAlluxioOnly, that.mAlluxioOnly)
&& Objects.equal(mUnchecked, that.mUnchecked);
}
@Override
public int hashCode() {
return Objects.hashCode(mRecursive, mAlluxioOnly, mUnchecked);
}
@Override
public String toString() {
return Objects.toStringHelper(this)
.add("recursive", mRecursive)
.add("alluxioOnly", mAlluxioOnly)
.add("skipConsistencyCheck", mUnchecked)
.toString();
}
}