/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 | 109 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 D | TestSnapshotListing.java | 76 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 D | TestSwiftFileSystemLsOperations.java | 75 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 D | TestSwiftFileSystemDirectories.java | 55 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 D | TestJobHistoryLocation.java | 127 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 D | FSVisitor.java | 74 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 D | FSUtils.java | 565 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 D | TestSetupWorkDir.java | 90 (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 D | TestGridmixCompressedInputGeneration.java | 151 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 D | TestFileStatus.java | 160 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 D | TestReservedRawPaths.java | 272 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 D | TestTableDeleteFamilyHandler.java | 131 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 D | TestWALReaderOnSecureWAL.java | 152 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 D | NativeS3FileSystemContractBaseTest.java | 65 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 D | NativeS3FileSystemContractBaseTest.java | 54 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 D | ParquetFileFormatSuite.scala | 44 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 D | TestFileInputFormat.java | 139 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 D | TestKosmosFileSystem.java | 76 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 D | TestFileStatus.java | 125 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 D | TestHFileOutputFormat2.java | 278 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 D | TestHFileOutputFormat.java | 273 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 D | Globber.java | 66 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 D | TestLogsCleaner.java | 126 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 D | FileContextURIBase.java | 494 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 D | FileSystem.java | 828 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 …]
|