| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/test/java/org/apache/hadoop/yarn/logaggregation/ |
| H A D | TestAggregatedLogDeletionService.java | 77 FileStatus userDirStatus = new FileStatus(0, true, 0, 0, toKeepTime, userDir); in testDeletion()
86 FileStatus app1DirStatus = new FileStatus(0, true, 0, 0, toDeleteTime, app1Dir); in testDeletion()
91 FileStatus app2DirStatus = new FileStatus(0, true, 0, 0, toDeleteTime, app2Dir); in testDeletion()
217 FileStatus userDirStatus = new FileStatus(0, true, 0, 0, before50Secs, in testRefreshLogRetentionSettings()
229 FileStatus app1DirStatus = new FileStatus(0, true, 0, 0, before2000Secs, in testRefreshLogRetentionSettings()
236 FileStatus app2DirStatus = new FileStatus(0, true, 0, 0, before50Secs, in testRefreshLogRetentionSettings()
243 FileStatus app1Log1Status = new FileStatus(10, false, 1, 1, before2000Secs, in testRefreshLogRetentionSettings()
250 FileStatus app2Log1Status = new FileStatus(10, false, 1, 1, before50Secs, in testRefreshLogRetentionSettings()
330 FileStatus userDirStatus = new FileStatus(0, true, 0, 0, now, userDir); in testCheckInterval()
339 FileStatus app1DirStatus = new FileStatus(0, true, 0, 0, now, app1Dir); in testCheckInterval()
[all …]
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/fs/ |
| H A D | TestFileStatus.java | 58 FileStatus[] tests = { in testFileStatusWritable()
78 FileStatus dest = new FileStatus(); in testFileStatusWritable()
95 FileStatus fileStatus = new FileStatus(LENGTH, isdir, REPLICATION, BLKSIZE, in constructorFull()
108 FileStatus fileStatus = new FileStatus(LENGTH, isdir, REPLICATION, BLKSIZE, in constructorNoSymlink()
121 FileStatus fileStatus = new FileStatus(LENGTH, isdir, in constructorNoOwner()
132 FileStatus fileStatus = new FileStatus(); in constructorBlank()
143 FileStatus fileStatus1 = new FileStatus(1, true, 1, 1, 1, 1, in testEquals()
145 FileStatus fileStatus2 = new FileStatus(2, true, 2, 2, 2, 2, in testEquals()
157 FileStatus fileStatus1 = new FileStatus(1, true, 1, 1, 1, 1, in testNotEquals()
159 FileStatus fileStatus2 = new FileStatus(1, true, 1, 1, 1, 1, in testNotEquals()
[all …]
|
| /dports/ftp/fineftp-server/fineftp-server-1.2.0/fineftp-server/src/ |
| H A D | filesystem.cpp | 30 FileStatus::FileStatus(const std::string& path) in FileStatus() function in fineftp::Filesystem::FileStatus
42 FileStatus::~FileStatus() {} in ~FileStatus()
44 bool FileStatus::isOk() const in isOk()
49 FileType FileStatus::type() const in type()
69 int64_t FileStatus::fileSize() const in fileSize()
100 std::string FileStatus::permissionString() const in permissionString()
137 std::string FileStatus::ownerString() const in ownerString()
142 std::string FileStatus::groupString() const in groupString()
147 std::string FileStatus::timeString() const in timeString()
235 bool FileStatus::canOpenDir() const in canOpenDir()
[all …]
|
| /dports/java/berkeley-db/je-6.2.31/src/com/sleepycat/je/cleaner/ |
| H A D | FileSelector.java | 43 private enum FileStatus { enum in FileSelector
114 FileStatus status;
214 setStatus(fileNum, FileStatus.TO_BE_CLEANED); in selectFileForCleaning()
227 setStatus(fileNum, FileStatus.BEING_CLEANED); in selectFileForCleaning()
319 private void setStatus(FileStatus oldStatus, FileStatus newStatus) { in setStatus()
389 setStatus(fileNum, FileStatus.TO_BE_CLEANED); in putBackFileForCleaning()
397 setStatus(fileNum, FileStatus.TO_BE_CLEANED); in injectFileForCleaning()
423 return getFiles(FileStatus.TO_BE_CLEANED); in getToBeCleanedFiles()
443 (getFiles(FileStatus.CLEANED), in getFilesAtCheckpointStart()
444 getFiles(FileStatus.FULLY_PROCESSED)); in getFilesAtCheckpointStart()
[all …]
|
| /dports/sysutils/kf5-baloo/baloo-5.89.0/src/tools/balooctl/ |
| H A D | statuscommand.cpp | 39 enum class FileStatus : uint8_t { enum in FileIndexStatus
57 FileStatus m_fileStatus;
64 using FileStatus = FileIndexStatus::FileStatus; in collectFileStatus() typedef
76 FileStatus fileStatus = fileInfo.isSymLink() ? FileStatus::SymLink : in collectFileStatus()
78 fileInfo.isDir() ? FileStatus::Directory : FileStatus::Other; in collectFileStatus()
80 if (fileStatus == FileStatus::Other || fileStatus == FileStatus::SymLink) { in collectFileStatus()
110 using FileStatus = FileIndexStatus::FileStatus; in printMultiLine() typedef
146 if (file.m_fileStatus == FileStatus::SymLink || file.m_fileStatus == FileStatus::Other) { in printMultiLine()
161 using FileStatus = FileIndexStatus::FileStatus; in printSimpleFormat() typedef
186 if (file.m_fileStatus == FileStatus::SymLink || file.m_fileStatus == FileStatus::Other) { in printSimpleFormat()
[all …]
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/ |
| H A D | Globber.java | 74 return new FileStatus[0]; in listStatus()
137 public FileStatus[] glob() throws IOException { in glob()
151 ArrayList<FileStatus> results = in glob()
166 ArrayList<FileStatus> candidates = new ArrayList<FileStatus>(1); in glob()
173 FileStatus rootPlaceholder; in glob()
190 ArrayList<FileStatus> newCandidates = in glob()
210 for (FileStatus candidate : candidates) { in glob()
215 for (FileStatus candidate : candidates) { in glob()
234 for (FileStatus child : children) { in glob()
261 for (FileStatus status : candidates) { in glob()
[all …]
|
| /dports/devel/spark/spark-2.1.1/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/ |
| H A D | FileStatusCache.scala | 25 import org.apache.hadoop.fs.{FileStatus, Path}
73 def getLeafFiles(path: Path): Option[Array[FileStatus]] = None
78 def putLeafFiles(path: Path, leafFiles: Array[FileStatus]): Unit
101 private val cache: Cache[(ClientId, Path), Array[FileStatus]] = {
107 val weigher = new Weigher[(ClientId, Path), Array[FileStatus]] {
122 Array[FileStatus]]): Unit = {
136 .build[(ClientId, Path), Array[FileStatus]]()
147 override def getLeafFiles(path: Path): Option[Array[FileStatus]] = {
151 override def putLeafFiles(path: Path, leafFiles: Array[FileStatus]): Unit = {
169 override def getLeafFiles(path: Path): Option[Array[FileStatus]] = None
[all …]
|
| /dports/devel/spark/spark-2.1.1/yarn/src/test/scala/org/apache/spark/deploy/yarn/ |
| H A D | ClientDistributedCacheManagerSuite.scala | 26 import org.apache.hadoop.fs.FileStatus
52 when(fs.getFileStatus(new Path(uri))).thenReturn(new FileStatus())
53 val statCache: Map[URI, FileStatus] = HashMap[URI, FileStatus]()
64 when(fs.getFileStatus(new Path(uri))).thenReturn(new FileStatus())
65 val statCache: Map[URI, FileStatus] = HashMap[URI, FileStatus](uri -> realFileStatus)
76 val statCache: Map[URI, FileStatus] = HashMap[URI, FileStatus]()
77 when(fs.getFileStatus(destPath)).thenReturn(new FileStatus())
135 val statCache: Map[URI, FileStatus] = HashMap[URI, FileStatus]()
136 when(fs.getFileStatus(destPath)).thenReturn(new FileStatus())
152 val statCache: Map[URI, FileStatus] = HashMap[URI, FileStatus]()
[all …]
|
| /dports/lang/ghc/ghc-8.10.7/libraries/unix/System/Posix/Files/ |
| H A D | Common.hsc | 47 FileStatus(..),
234 newtype FileStatus = FileStatus (ForeignPtr CStat) constructor
266 deviceID (FileStatus stat) =
268 fileID (FileStatus stat) =
270 fileMode (FileStatus stat) =
272 linkCount (FileStatus stat) =
274 fileOwner (FileStatus stat) =
276 fileGroup (FileStatus stat) =
280 fileSize (FileStatus stat) =
282 accessTime (FileStatus stat) =
[all …]
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/util/ |
| H A D | FSVisitor.java | 27 import org.apache.hadoop.fs.FileStatus;
82 for (FileStatus region: regions) { in visitRegions()
105 for (FileStatus region: regions) { in visitTableStoreFiles()
129 for (FileStatus family: families) { in visitRegionStoreFiles()
142 for (FileStatus hfile: storeFiles) { in visitRegionStoreFiles()
167 for (FileStatus region: regions) { in visitTableRecoveredEdits()
187 FileStatus stat = fs.getFileStatus(source); in visitRegionRecoveredEdits()
205 FileStatus[] logServerDirs = FSUtils.listStatus(fs, logsDir); in visitLogFiles()
213 for (FileStatus serverLogs: logServerDirs) { in visitLogFiles()
216 FileStatus[] wals = FSUtils.listStatus(fs, serverLogs.getPath()); in visitLogFiles()
[all …]
|
| /dports/devel/hadoop/hadoop-1.2.1/src/tools/org/apache/hadoop/tools/distcp2/ |
| H A D | SimpleCopyListing.java | 25 import org.apache.hadoop.fs.FileStatus;
120 FileStatus rootStatus = sourceFS.getFileStatus(path); in doBuildListing()
124 FileStatus[] sourceFiles = sourceFS.listStatus(path); in doBuildListing()
126 for (FileStatus sourceStatus: sourceFiles) { in doBuildListing()
151 private Path computeSourceRootPath(FileStatus sourceStatus, in computeSourceRootPath()
217 private static FileStatus[] getChildren(FileSystem fileSystem, in getChildren()
229 Stack<FileStatus> pathStack = new Stack<FileStatus>(); in traverseNonEmptyDirectory()
250 FileStatus fileStatus, in writeToFileListing()
262 FileStatus status = fileStatus; in writeToFileListing()
284 private FileStatus getFileStatus(FileStatus fileStatus) throws IOException { in getFileStatus()
[all …]
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/master/cleaner/ |
| H A D | CleanerChore.java | 27 import org.apache.hadoop.fs.FileStatus;
123 FileStatus[] files = FSUtils.listStatus(this.fs, this.oldFileDir); in chore()
139 private boolean checkAndDeleteEntries(FileStatus[] entries) { in checkAndDeleteEntries()
145 for (FileStatus child : entries) { in checkAndDeleteEntries()
179 FileStatus[] children = FSUtils.listStatus(fs, dir); in checkAndDeleteDirectory()
211 private boolean checkAndDeleteFiles(List<FileStatus> files) { in checkAndDeleteFiles()
214 List<FileStatus> invalidFiles = Lists.newArrayList(); in checkAndDeleteFiles()
215 for (FileStatus file : files) { in checkAndDeleteFiles()
224 Iterable<FileStatus> deletableValidFiles = validFiles; in checkAndDeleteFiles()
238 for (FileStatus file : deletableValidFiles) { in checkAndDeleteFiles()
[all …]
|
| H A D | BaseFileCleanerDelegate.java | 20 import org.apache.hadoop.fs.FileStatus;
34 public Iterable<FileStatus> getDeletableFiles(Iterable<FileStatus> files) { in getDeletableFiles()
35 return Iterables.filter(files, new Predicate<FileStatus>() { in getDeletableFiles()
37 public boolean apply(FileStatus file) { in getDeletableFiles()
47 protected abstract boolean isFileDeletable(FileStatus fStat);
|
| /dports/devel/hadoop/hadoop-1.2.1/src/test/system/java/org/apache/hadoop/mapred/ |
| H A D | TestJobHistoryLocation.java | 33 import org.apache.hadoop.fs.FileStatus;
126 FileStatus[] jobHistoryDoneFileStatuses = dfs. in testRetiredJobsHistoryLocation()
144 FileStatus[] jobHistoryFileStatuses = dfs. in testRetiredJobsHistoryLocation()
212 FileStatus[] jobHistoryDoneFileStatuses; in testRetiredMultipleJobsHistoryLocation()
321 FileStatus[] jobHistoryDoneFileStatuses1 = dfs. in checkJobHistoryFileInformation()
324 FileStatus[] jobHistoryDoneFileStatuses2 = dfs. in checkJobHistoryFileInformation()
326 for (FileStatus jobHistoryDoneFileStatus2 : in checkJobHistoryFileInformation()
329 FileStatus[] jobHistoryDoneFileStatuses3 = dfs. in checkJobHistoryFileInformation()
331 for (FileStatus jobHistoryDoneFileStatus3 : in checkJobHistoryFileInformation()
336 for (FileStatus jobHistoryDoneFileStatus4 : in checkJobHistoryFileInformation()
[all …]
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/util/ |
| H A D | HFileArchiveTestingUtil.java | 32 import org.apache.hadoop.fs.FileStatus;
50 public static boolean compareArchiveToOriginal(FileStatus[] previous, FileStatus[] archived, in compareArchiveToOriginal()
92 public static void assertArchiveEqualToOriginal(FileStatus[] expected, FileStatus[] actual, in assertArchiveEqualToOriginal()
106 public static void assertArchiveEqualToOriginal(FileStatus[] expected, FileStatus[] actual, in assertArchiveEqualToOriginal()
145 private static List<List<String>> getFileLists(FileStatus[] previous, FileStatus[] archived) { in getFileLists()
153 List<FileStatus> backedupFiles = new ArrayList<FileStatus>(previous.length); in getFileLists()
154 for (FileStatus f : archived) { in getFileLists()
161 FileStatus file = new FileStatus(f.getLen(), f.isDirectory(), f.getReplication(), in getFileLists()
175 private static List<String> convertToString(FileStatus[] files) { in convertToString()
179 private static List<String> convertToString(List<FileStatus> files) { in convertToString()
[all …]
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/jobhistory/ |
| H A D | JobHistoryUtils.java | 38 import org.apache.hadoop.fs.FileStatus;
459 List<List<FileStatus>> subsubdirs = new LinkedList<List<FileStatus>>(); in localGlobber()
464 return new LinkedList<FileStatus>(); in localGlobber()
476 List<FileStatus> result = new LinkedList<FileStatus>(); in localGlobber()
509 List<FileStatus> filteredList = new LinkedList<FileStatus>(); in listFilteredStatus()
510 for (FileStatus fs : fsList) { in listFilteredStatus()
519 private static List<FileStatus> remoteIterToList( in remoteIterToList()
521 List<FileStatus> fsList = new LinkedList<FileStatus>(); in remoteIterToList()
585 List<FileStatus> fsList = new ArrayList<FileStatus>(); in getHistoryDirsForCleaning()
594 FileStatus yearDir = yearDirIt.next(); in getHistoryDirsForCleaning()
[all …]
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-tools/hadoop-gridmix/src/main/java/org/apache/hadoop/mapred/gridmix/ |
| H A D | FilePool.java | 36 import org.apache.hadoop.fs.FileStatus;
84 public long getInputFiles(long minSize, Collection<FileStatus> files) in getInputFiles()
145 final ArrayList<FileStatus> curdir;
147 LeafDesc(ArrayList<FileStatus> curdir, long size) { in LeafDesc()
158 public long selectFiles(long targetSize, Collection<FileStatus> files) in selectFiles()
203 final ArrayList<FileStatus> curFiles = new ArrayList<FileStatus>(); in InnerDesc()
204 final ArrayList<FileStatus> curDirs = new ArrayList<FileStatus>(); in InnerDesc()
205 for (FileStatus stat : fs.listStatus(thisDir.getPath())) { in InnerDesc()
217 for (Iterator<FileStatus> i = curDirs.iterator(); in InnerDesc()
244 public long selectFiles(long targetSize, Collection<FileStatus> files) in selectFiles()
[all …]
|
| /dports/devel/hadoop/hadoop-1.2.1/src/contrib/gridmix/src/java/org/apache/hadoop/mapred/gridmix/ |
| H A D | FilePool.java | 36 import org.apache.hadoop.fs.FileStatus;
84 public long getInputFiles(long minSize, Collection<FileStatus> files) in getInputFiles()
145 final ArrayList<FileStatus> curdir;
147 LeafDesc(ArrayList<FileStatus> curdir, long size) { in LeafDesc()
158 public long selectFiles(long targetSize, Collection<FileStatus> files) in selectFiles()
203 final ArrayList<FileStatus> curFiles = new ArrayList<FileStatus>(); in InnerDesc()
204 final ArrayList<FileStatus> curDirs = new ArrayList<FileStatus>(); in InnerDesc()
205 for (FileStatus stat : fs.listStatus(thisDir.getPath())) { in InnerDesc()
217 for (Iterator<FileStatus> i = curDirs.iterator(); in InnerDesc()
244 public long selectFiles(long targetSize, Collection<FileStatus> files) in selectFiles()
[all …]
|
| /dports/devel/hadoop/hadoop-1.2.1/src/tools/org/apache/hadoop/tools/rumen/ |
| H A D | TraceBuilder.java | 36 import org.apache.hadoop.fs.FileStatus;
99 implements Comparator<FileStatus> {
101 public int compare(FileStatus file1, FileStatus file2) { in compare()
123 List<FileStatus> list = new ArrayList<FileStatus>(); in listFiles()
124 FileStatus[] statuses = fs.listStatus(path, filter); in listFiles()
126 for (FileStatus status : statuses) { in listFiles()
164 FileStatus[] inStatuses = fs.globStatus(inPath); in processInputArgument()
171 for (FileStatus inStatus : inStatuses) { in processInputArgument()
177 List<FileStatus> historyLogs = new ArrayList<FileStatus>(); in processInputArgument()
181 for (FileStatus child : statuses) { in processInputArgument()
[all …]
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-tools/hadoop-openstack/src/test/java/org/apache/hadoop/fs/swift/ |
| H A D | TestSwiftFileSystemLsOperations.java | 21 import org.apache.hadoop.fs.FileStatus;
75 FileStatus[] paths = fs.listStatus(path("/test")); in testListLevelTest()
83 FileStatus[] paths; in testListLevelTestHadoop()
98 FileStatus[] paths; in testListStatusEmptyDirectory()
110 FileStatus[] pathStats = fs.listStatus(file); in testListStatusFile()
115 FileStatus lsStat = pathStats[0]; in testListStatusFile()
125 FileStatus[] fileStatuses = fs.listStatus(path("/")); in testListEmptyRoot()
135 FileStatus[] fileStatuses = fs.listStatus(path("/")); in testListNonEmptyRoot()
138 FileStatus status = fileStatuses[0]; in testListNonEmptyRoot()
155 FileStatus[] stats = fs.listStatus(dir, new AcceptAllFilter()); in testListStatusFiltered()
[all …]
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/filecache/ |
| H A D | ClientDistributedCacheManager.java | 27 import org.apache.hadoop.fs.FileStatus;
56 Map<URI, FileStatus> statCache = new HashMap<URI, FileStatus>(); in determineTimestampsAndCacheVisibilities()
72 Map<URI, FileStatus> statCache) throws IOException { in determineTimestamps()
93 FileStatus status = getFileStatus(job, tfiles[0], statCache); in determineTimestamps()
149 Map<URI, FileStatus> statCache) throws IOException { in determineCacheVisibilities()
222 Map<URI, FileStatus> statCache) throws IOException { in getFileStatus()
236 Map<URI, FileStatus> statCache) throws IOException { in isPublic()
252 Map<URI, FileStatus> statCache) throws IOException { in ancestorsHaveExecutePermissions()
284 private static FileStatus getFileStatus(FileSystem fs, URI uri, in getFileStatus()
285 Map<URI, FileStatus> statCache) throws IOException { in getFileStatus()
[all …]
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-hs/src/test/java/org/apache/hadoop/mapreduce/v2/hs/ |
| H A D | TestJobHistory.java | 29 import org.apache.hadoop.fs.FileStatus;
131 FileStatus dirCreatedYesterdayStatus = new FileStatus(0, true, 0, 0, in testRefreshJobRetentionSettings()
141 FileStatus dirCreatedTodayStatus = new FileStatus(0, true, 0, 0, in testRefreshJobRetentionSettings()
148 FileStatus fileUnderYesterdayDirStatus = new FileStatus(10, false, 0, 0, in testRefreshJobRetentionSettings()
155 FileStatus fileUnderTodayDirStatus = new FileStatus(10, false, 0, 0, in testRefreshJobRetentionSettings()
161 List<FileStatus> fileStatusList = new LinkedList<FileStatus>(); in testRefreshJobRetentionSettings()
169 List<FileStatus> list1 = new LinkedList<FileStatus>(); in testRefreshJobRetentionSettings()
174 List<FileStatus> list2 = new LinkedList<FileStatus>(); in testRefreshJobRetentionSettings()
181 doReturn(true).when(historyManager).deleteDir(any(FileStatus.class)); in testRefreshJobRetentionSettings()
|
| /dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/tools/distcp2/ |
| H A D | StubContext.java | 26 import org.apache.hadoop.fs.FileStatus;
40 private RecordReader<Text, FileStatus> reader;
42 private Mapper<Text, FileStatus, Text, Text>.Context mapperContext;
44 public StubContext(Configuration conf, RecordReader<Text, FileStatus> reader, in StubContext()
47 Mapper<Text, FileStatus, Text, Text> mapper in StubContext()
48 = new Mapper<Text, FileStatus, Text, Text>(); in StubContext()
50 Mapper<Text, FileStatus, Text, Text>.Context contextImpl in StubContext()
59 public Mapper<Text, FileStatus, Text, Text>.Context getContext() { in getContext()
67 public RecordReader<Text, FileStatus> getReader() { in getReader()
|
| /dports/graphics/rx/rx-0.4.0/src/ |
| H A D | view.rs | 171 pub file_status: FileStatus,
229 FileStatus::New(ref f) => Some(f), in file_storage()
231 FileStatus::Saved(ref f) => Some(f), in file_storage()
232 FileStatus::NoFile => None, in file_storage()
240 FileStatus::Modified(ref curr_fs) | FileStatus::New(ref curr_fs) => { in save_as()
245 FileStatus::NoFile => { in save_as()
248 FileStatus::Saved(_) => {} in save_as()
339 FileStatus::Saved(ref f) => { in restore()
486 pub enum FileStatus { enum
497 impl ToString for FileStatus { implementation
[all …]
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/master/snapshot/ |
| H A D | SnapshotFileCache.java | 38 import org.apache.hadoop.fs.FileStatus;
179 public synchronized Iterable<FileStatus> getUnreferencedFiles(Iterable<FileStatus> files) in getUnreferencedFiles()
181 List<FileStatus> unReferencedFiles = Lists.newArrayList(); in getUnreferencedFiles()
184 for (FileStatus file : files) { in getUnreferencedFiles()
210 FileStatus dirStatus = fs.getFileStatus(snapshotDir); in refreshCache()
224 FileStatus tempDirStatus = fs.getFileStatus(snapshotTmpDir); in refreshCache()
230 for (FileStatus dirStatus: tmpSnapshots) { in refreshCache()
258 FileStatus[] snapshots = FSUtils.listStatus(fs, snapshotDir); in refreshCache()
269 for (FileStatus snapshot : snapshots) { in refreshCache()
300 FileStatus[] running = FSUtils.listStatus(fs, snapshotTmpDir); in getSnapshotsInProgress()
[all …]
|