Home
last modified time | relevance | path

Searched refs:listStatus (Results 1 – 25 of 484) sorted by relevance

12345678910>>...20

/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 DTestAggregatedLogDeletionService.java109 when(mockFs.listStatus(userLogDir)).thenReturn( in testDeletion()
113 when(mockFs.listStatus(app1Dir)).thenReturn( in testDeletion()
122 when(mockFs.listStatus(app2Dir)).thenReturn( in testDeletion()
133 when(mockFs.listStatus(app3Dir)).thenReturn( in testDeletion()
142 when(mockFs.listStatus(app4Dir)).thenReturn( in testDeletion()
151 when(mockFs.listStatus(app5Dir)).thenReturn( in testDeletion()
239 when(mockFs.listStatus(userLogDir)).thenReturn( in testRefreshLogRetentionSettings()
246 when(mockFs.listStatus(app1Dir)).thenReturn( in testRefreshLogRetentionSettings()
253 when(mockFs.listStatus(app2Dir)).thenReturn( in testRefreshLogRetentionSettings()
347 when(mockFs.listStatus(app1Dir)).thenReturn( in testCheckInterval()
[all …]
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/namenode/snapshot/
H A DTestSnapshotListing.java76 stats = hdfs.listStatus(new Path("/.snapshot")); in testListSnapshots()
82 stats = hdfs.listStatus(snapshotsPath); in testListSnapshots()
91 stats = hdfs.listStatus(snapshotsPath); in testListSnapshots()
98 stats = hdfs.listStatus(snapshotsPath); in testListSnapshots()
108 stats = hdfs.listStatus(snapshotsPath); in testListSnapshots()
117 stats = hdfs.listStatus(snapshotsPath); in testListSnapshots()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-tools/hadoop-openstack/src/test/java/org/apache/hadoop/fs/swift/
H A DTestSwiftFileSystemLsOperations.java75 FileStatus[] paths = fs.listStatus(path("/test")); in testListLevelTest()
84 paths = fs.listStatus(path("/test/hadoop")); in testListLevelTestHadoop()
99 paths = fs.listStatus(path("/test/hadoop/a")); in testListStatusEmptyDirectory()
110 FileStatus[] pathStats = fs.listStatus(file); in testListStatusFile()
125 FileStatus[] fileStatuses = fs.listStatus(path("/")); in testListEmptyRoot()
135 FileStatus[] fileStatuses = fs.listStatus(path("/")); in testListNonEmptyRoot()
155 FileStatus[] stats = fs.listStatus(dir, new AcceptAllFilter()); in testListStatusFiltered()
H A DTestSwiftFileSystemDirectories.java55 FileStatus[] statuses = fs.listStatus(missing); in testNoStatusForMissingDirectories()
75 FileStatus[] statuses = fs.listStatus(test); in testDirectoriesOffRootHaveMatchingFileStatus()
85 statuses = fs.listStatus(test); in testDirectoriesOffRootHaveMatchingFileStatus()
106 FileStatus[] statuses = fs.listStatus(test); in testDirectoriesLowerDownHaveMatchingFileStatus()
/dports/devel/hadoop/hadoop-1.2.1/src/test/system/java/org/apache/hadoop/mapred/
H A DTestJobHistoryLocation.java127 listStatus(new Path (jobHistoryDonePathString)); in testRetiredJobsHistoryLocation()
145 listStatus(new Path (jobHistoryPathString)); in testRetiredJobsHistoryLocation()
187 listStatus(new Path (jobHistoryDonePathString)); in testRetiredJobsHistoryLocation()
281 listStatus(new Path (jobHistoryDonePathString)); in testRetiredMultipleJobsHistoryLocation()
322 listStatus(jobHistoryDoneFileStatus.getPath()); in checkJobHistoryFileInformation()
325 listStatus(jobHistoryDoneFileStatus1.getPath()); in checkJobHistoryFileInformation()
330 listStatus(jobHistoryDoneFileStatus2.getPath()); in checkJobHistoryFileInformation()
335 listStatus(jobHistoryDoneFileStatus3.getPath()); in checkJobHistoryFileInformation()
340 listStatus(jobHistoryDoneFileStatus4.getPath()); in checkJobHistoryFileInformation()
345 listStatus(jobHistoryDoneFileStatus5.getPath()); in checkJobHistoryFileInformation()
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/util/
H A DFSVisitor.java74 FileStatus[] regions = FSUtils.listStatus(fs, tableDir, new FSUtils.RegionDirFilter(fs)); in visitRegions()
97 FileStatus[] regions = FSUtils.listStatus(fs, tableDir, new FSUtils.RegionDirFilter(fs)); in visitTableStoreFiles()
120 FileStatus[] families = FSUtils.listStatus(fs, regionDir, new FSUtils.FamilyDirFilter(fs)); in visitRegionStoreFiles()
134 FileStatus[] storeFiles = FSUtils.listStatus(fs, familyDir, fileFilter); in visitRegionStoreFiles()
159 FileStatus[] regions = FSUtils.listStatus(fs, tableDir, new FSUtils.RegionDirFilter(fs)); in visitTableRecoveredEdits()
205 FileStatus[] logServerDirs = FSUtils.listStatus(fs, logsDir); in visitLogFiles()
216 FileStatus[] wals = FSUtils.listStatus(fs, serverLogs.getPath()); in visitLogFiles()
H A DFSUtils.java565 status = fs.listStatus(versionFile); in getVersion()
1072 FileStatus[] regionDirs = fs.listStatus(d, regionFilter); in isMajorCompacted()
1080 FileStatus[] familyStatus = fs.listStatus(family); in isMajorCompacted()
1148 FileStatus[] regionDirs = fs.listStatus(d, regionFilter); in getTableFragmentation()
1158 FileStatus[] familyStatus = fs.listStatus(family); in getTableFragmentation()
1622 FileStatus[] familyDirs = fs.listStatus(dd, familyFilter); in getTableStoreFilePathMap()
1633 FileStatus[] familyStatus = fs.listStatus(family); in getTableStoreFilePathMap()
1718 public static FileStatus [] listStatus(final FileSystem fs, in listStatus() method in FSUtils
1722 status = filter == null ? fs.listStatus(dir) : fs.listStatus(dir, filter); in listStatus()
1742 return listStatus(fs, dir, null); in listStatus()
[all …]
/dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/mapred/
H A DTestSetupWorkDir.java90 (fs.listStatus(myWorkDir).length == 4) && in testSetupWorkDir()
91 (fs.listStatus(myTargetDir).length == 2)); in testSetupWorkDir()
103 fs.exists(myWorkDir) && (fs.listStatus(myWorkDir).length == 1)); in testSetupWorkDir()
106 assertTrue(fs.listStatus(myWorkDir)[0].getPath().toUri().getPath() in testSetupWorkDir()
111 fs.exists(myTargetDir) && (fs.listStatus(myTargetDir).length == 2)); in testSetupWorkDir()
/dports/devel/hadoop/hadoop-1.2.1/src/contrib/gridmix/src/test/system/org/apache/hadoop/mapred/gridmix/
H A DTestGridmixCompressedInputGeneration.java151 FileStatus [] listStatus = fs.listStatus(inputDir); in getInputFiles() local
153 for (FileStatus fileStat : listStatus) { in getInputFiles()
167 FileStatus [] listStatus = fs.listStatus(fstatus.getPath()); in getInputFile() local
168 for (FileStatus fileStat : listStatus) { in getInputFile()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/
H A DTestFileStatus.java160 FileStatus[] stats = fs.listStatus(file1); in testListStatusOnFile()
182 fs.listStatus(dir); in testGetFileStatusOnNonExistantFileDir()
189 fc.listStatus(dir); in testGetFileStatusOnNonExistantFileDir()
220 FileStatus[] stats = fs.listStatus(dir); in testGetFileStatusOnDir()
227 RemoteIterator<FileStatus> itor = fc.listStatus(dir); in testGetFileStatusOnDir()
260 stats = fs.listStatus(dir); in testGetFileStatusOnDir()
265 itor = fc.listStatus(dir); in testGetFileStatusOnDir()
280 stats = fs.listStatus(dir); in testGetFileStatusOnDir()
286 itor = fc.listStatus(dir); in testGetFileStatusOnDir()
305 stats = fs.listStatus(dir); in testGetFileStatusOnDir()
[all …]
H A DTestReservedRawPaths.java272 fs.listStatus(ezRawEncFile); in testAdminAccessOnly()
310 fs.listStatus(new Path("/.reserved")); in testListDotReserved()
317 fs.listStatus(new Path("/.reserved/.inodes")); in testListDotReserved()
324 final FileStatus[] fileStatuses = fs.listStatus(new Path("/.reserved/raw")); in testListDotReserved()
340 FileStatus[] fileStatuses = fs.listStatus(curPath); in testListRecursive()
346 fileStatuses = fs.listStatus(curPath); in testListRecursive()
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/master/handler/
H A DTestTableDeleteFamilyHandler.java131 FileStatus[] fileStatus = fs.listStatus(tableDir); in deleteColumnFamilyWithMultipleRegions()
134 FileStatus[] cf = fs.listStatus(fileStatus[i].getPath(), new PathFilter() { in deleteColumnFamilyWithMultipleRegions()
166 fileStatus = fs.listStatus(tableDir); in deleteColumnFamilyWithMultipleRegions()
169 FileStatus[] cf = fs.listStatus(fileStatus[i].getPath(), new PathFilter() { in deleteColumnFamilyWithMultipleRegions()
216 FileStatus[] fileStatus = fs.listStatus(tableDir); in deleteColumnFamilyTwice()
220 FileStatus[] cf = fs.listStatus(fileStatus[i].getPath(), new PathFilter() { in deleteColumnFamilyTwice()
249 fileStatus = fs.listStatus(tableDir); in deleteColumnFamilyTwice()
252 FileStatus[] cf = fs.listStatus(fileStatus[i].getPath(), new PathFilter() { in deleteColumnFamilyTwice()
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/wal/
H A DTestWALReaderOnSecureWAL.java152 FileStatus[] listStatus = fs.listStatus(walPath.getParent()); in testWALReaderOnSecureWAL() local
158 s.splitLogFile(listStatus[0], null); in testWALReaderOnSecureWAL()
159 Path file = new Path(ZKSplitLog.getSplitLogDir(rootdir, listStatus[0].getPath().getName()), in testWALReaderOnSecureWAL()
197 FileStatus[] listStatus = fs.listStatus(walPath.getParent()); in testSecureWALReaderOnWAL() local
203 s.splitLogFile(listStatus[0], null); in testSecureWALReaderOnWAL()
204 Path file = new Path(ZKSplitLog.getSplitLogDir(rootdir, listStatus[0].getPath().getName()), in testSecureWALReaderOnWAL()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3native/
H A DNativeS3FileSystemContractBaseTest.java65 FileStatus[] paths = fs.listStatus(path("/")); in testListStatusForRoot()
71 paths = fs.listStatus(path("/")); in testListStatusForRoot()
116 assertEquals(2, fs.listStatus(path).length); in testDirWithDifferentMarkersWorks()
130 assertEquals(0, fs.listStatus(path).length); in testDeleteWithNoMarker()
143 assertEquals(1, fs.listStatus(path).length); in testRenameWithNoMarker()
145 assertEquals(2, fs.listStatus(dest).length); in testRenameWithNoMarker()
/dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/fs/s3native/
H A DNativeS3FileSystemContractBaseTest.java54 FileStatus[] paths = fs.listStatus(path("/")); in testListStatusForRoot()
95 assertEquals(2, fs.listStatus(path).length); in testDirWithDifferentMarkersWorks()
120 assertEquals(1, fs.listStatus(path).length); in testRenameWithNoMarker()
122 assertEquals(2, fs.listStatus(dest).length); in testRenameWithNoMarker()
/dports/devel/spark/spark-2.1.1/sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/parquet/
H A DParquetFileFormatSuite.scala44 Seq(fs.listStatus(path1), fs.listStatus(path2), fs.listStatus(path3)).flatten
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/test/java/org/apache/hadoop/mapred/
H A DTestFileInputFormat.java139 FileStatus[] statuses = fif.listStatus(jobConf); in testListStatusSimple()
156 FileStatus[] statuses = fif.listStatus(jobConf); in testListStatusNestedRecursive()
173 FileStatus[] statuses = fif.listStatus(jobConf); in testListStatusNestedNonRecursive()
191 fif.listStatus(jobConf); in testListStatusErrorOnNonExistantDir()
216 public FileStatus[] listStatus(Path f) throws FileNotFoundException, in listStatus() method in TestFileInputFormat.MockFileSystem
240 public FileStatus[] listStatus(Path f, PathFilter filter) in listStatus() method in TestFileInputFormat.MockFileSystem
242 return this.listStatus(f); in listStatus()
/dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/fs/kfs/
H A DTestKosmosFileSystem.java76 FileStatus[] p = kosmosFileSystem.listStatus(baseDir); in testDirs()
102 FileStatus[] p = kosmosFileSystem.listStatus(subDir1); in testFiles()
106 p = kosmosFileSystem.listStatus(subDir1); in testFiles()
110 p = kosmosFileSystem.listStatus(subDir1); in testFiles()
/dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/hdfs/
H A DTestFileStatus.java125 FileStatus[] stats = fs.listStatus(file1); in testFileStatus()
140 stats = fs.listStatus(dir); in testFileStatus()
162 stats = fs.listStatus(dir); in testFileStatus()
205 stats = fs.listStatus(dir); in testFileStatus()
215 stats = fs.listStatus(dir); in testFileStatus()
228 stats = fs.listStatus(dir); in testFileStatus()
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/mapreduce/
H A DTestHFileOutputFormat2.java278 FileStatus[] sub1 = fs.listStatus(attemptDirectory);
339 FileStatus [] files = fs.listStatus(testDir);
942 assertEquals(0, fs.listStatus(storePath).length);
962 assertEquals(2, fs.listStatus(storePath).length);
970 return fs.listStatus(storePath).length == 1;
983 return fs.listStatus(storePath).length == 1;
1011 assertEquals(0, fs.listStatus(storePath).length);
1022 return fs.listStatus(storePath).length == 1;
1042 assertEquals(2, fs.listStatus(storePath).length);
1050 return fs.listStatus(storePath).length == 1;
[all …]
H A DTestHFileOutputFormat.java273 FileStatus[] sub1 = fs.listStatus(attemptDirectory);
334 FileStatus [] files = fs.listStatus(testDir);
925 assertEquals(0, fs.listStatus(storePath).length);
944 assertEquals(2, fs.listStatus(storePath).length);
951 return fs.listStatus(storePath).length == 1;
963 return fs.listStatus(storePath).length == 1;
992 assertEquals(0, fs.listStatus(storePath).length);
1002 return fs.listStatus(storePath).length == 1;
1020 assertEquals(2, fs.listStatus(storePath).length);
1027 return fs.listStatus(storePath).length == 1;
[all …]
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/
H A DGlobber.java66 private FileStatus[] listStatus(Path path) throws IOException { in listStatus() method in Globber
69 return fs.listStatus(path); in listStatus()
71 return fc.util().listStatus(path); in listStatus()
217 FileStatus[] children = listStatus(candidate.getPath()); in glob()
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/master/cleaner/
H A DTestLogsCleaner.java126 for (FileStatus stat : fs.listStatus(oldLogDir)) { in testLogCleaning()
130 assertEquals(34, fs.listStatus(oldLogDir).length); in testLogCleaning()
141 return 5 == fs.listStatus(oldLogDir).length; in testLogCleaning()
145 for (FileStatus file : fs.listStatus(oldLogDir)) { in testLogCleaning()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/fs/
H A DFileContextURIBase.java494 fc1.listStatus(testPath); in testListStatusThrowsExceptionForNonExistentFile()
528 FileStatus[] paths = fc1.util().listStatus(qualifiedPath("test", fc1)); in testListStatus()
532 paths = fc1.util().listStatus(qualifiedPath(hPrefix, fc1)); in testListStatus()
546 paths = fc1.util().listStatus(qualifiedPath(dirs[0], fc1)); in testListStatus()
551 fc1.listStatus(qualifiedPath("test", fc1)); in testListStatus()
555 pathsItor = fc1.listStatus(qualifiedPath(hPrefix, fc1)); in testListStatus()
570 pathsItor = fc1.listStatus(qualifiedPath(dirs[0], fc1)); in testListStatus()
/dports/devel/hadoop/hadoop-1.2.1/src/core/org/apache/hadoop/fs/
H A DFileSystem.java828 for(FileStatus s : listStatus(f)) {
860 private void listStatus(ArrayList<FileStatus> results, Path f,
862 FileStatus listing[] = listStatus(f);
887 listStatus(results, f, filter);
901 public FileStatus[] listStatus(Path[] files)
903 return listStatus(files, DEFAULT_FILTER);
918 public FileStatus[] listStatus(Path[] files, PathFilter filter)
922 listStatus(results, files[i], filter);
1052 results = listStatus(parentPaths, fp);
1101 parents = FileUtil.stat2Paths(listStatus(parents, fp));
[all …]

12345678910>>...20