/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-tools/hadoop-distcp/src/test/java/org/apache/hadoop/tools/util/ |
H A D | TestDistCpUtils.java | 171 Assert.assertTrue(srcStatus.getReplication() == dstStatus.getReplication()); in testPreserveDefaults() 325 Assert.assertTrue(srcStatus.getReplication() == dstStatus.getReplication()); in testPreserveReplicationOnDirectory() 394 Assert.assertFalse(srcStatus.getReplication() == dstStatus.getReplication()); in testPreserveNothingOnFile() 430 Assert.assertFalse(srcStatus.getReplication() == dstStatus.getReplication()); in testPreservePermissionOnFile() 466 Assert.assertFalse(srcStatus.getReplication() == dstStatus.getReplication()); in testPreserveGroupOnFile() 538 Assert.assertTrue(srcStatus.getReplication() == dstStatus.getReplication()); in testPreserveReplicationOnFile() 640 Assert.assertTrue(srcStatus.getReplication() == f2Status.getReplication()); in testPreserveOnFileUpwardRecursion() 649 Assert.assertFalse(srcStatus.getReplication() == f1Status.getReplication()); in testPreserveOnFileUpwardRecursion() 743 Assert.assertTrue(srcStatus.getReplication() != d2Status.getReplication()); in testPreserveOnDirectoryUpwardRecursion() 752 Assert.assertTrue(srcStatus.getReplication() != d1Status.getReplication()); in testPreserveOnDirectoryUpwardRecursion() [all …]
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/ |
H A D | CacheReplicationMonitor.java | 378 directive.getReplication(); in rescanFile() 408 directive.getReplication(), mark); in rescanFile() 423 directive.getReplication()) * blockInfo.getNumBytes(); in rescanFile() 427 (ocblock.getReplication() < directive.getReplication())) { in rescanFile() 440 ocblock.setReplicationAndMark(directive.getReplication(), mark); in rescanFile() 444 directive.getId(), blockInfo, ocblock.getReplication()); in rescanFile() 472 } else if (cblock.getReplication() == 0) { in findReasonForNotCaching() 524 neededCached = cblock.getReplication(); in rescanCachedBlockMap() 713 (cachedBlock.getReplication() - neededCached + chosen.size()), in addNewPendingCached() 714 cachedBlock.getReplication(), outOfCapacity in addNewPendingCached()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/protocol/ |
H A D | CacheDirectiveInfo.java | 69 this.replication = directive.getReplication(); in Builder() 285 public Short getReplication() { in getReplication() method in CacheDirectiveInfo 314 append(getReplication(), other.getReplication()). in equals()
|
H A D | HdfsFileStatus.java | 134 public final short getReplication() { in getReplication() method in HdfsFileStatus 263 return new FileStatus(getLen(), isDir(), getReplication(), in makeQualified()
|
H A D | SnapshottableDirectoryStatus.java | 130 maxRepl = maxLength(maxRepl, status.dirStatus.getReplication()); in print() 155 status.dirStatus.getReplication(), in print()
|
H A D | CacheDirective.java | 59 info.getReplication(), in CacheDirective() 81 public short getReplication() { in getReplication() method in CacheDirective
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/fs/ |
H A D | TestSymlinkHdfs.java | 252 assertEquals(0, wrapper.getFileLinkStatus(link).getReplication()); in testSetReplication() 253 assertEquals(2, wrapper.getFileStatus(link).getReplication()); in testSetReplication() 254 assertEquals(2, wrapper.getFileStatus(file).getReplication()); in testSetReplication() 313 assertEquals(0, wrapper.getFileLinkStatus(link).getReplication()); in testWebHDFS() 314 assertEquals(2, wrapper.getFileStatus(link).getReplication()); in testWebHDFS() 315 assertEquals(2, wrapper.getFileStatus(file).getReplication()); in testWebHDFS()
|
/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 | TestRenameWithSnapshots.java | 369 assertEquals(REPL, status.getReplication()); in testRenameDirAcrossSnapshottableDirs() 402 assertEquals(REPL, status.getReplication()); in testRenameFileAcrossSnapshottableDirs() 578 assertEquals(REPL_2, status.getReplication()); in testRenameFileAndDeleteSnapshot() 581 assertEquals(REPL_1, status.getReplication()); in testRenameFileAndDeleteSnapshot() 586 assertEquals(REPL_2, status.getReplication()); in testRenameFileAndDeleteSnapshot() 593 assertEquals(REPL_1, status.getReplication()); in testRenameFileAndDeleteSnapshot() 606 assertEquals(REPL, status.getReplication()); in testRenameFileAndDeleteSnapshot() 910 assertEquals(REPL, statusBar.getReplication()); in testRenameMoreThanOnceAcrossSnapDirs_2() 959 assertEquals(REPL, statusBar.getReplication()); in testRenameMoreThanOnceAcrossSnapDirs_2() 961 assertEquals(REPL, statusBar.getReplication()); in testRenameMoreThanOnceAcrossSnapDirs_2() [all …]
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/viewfs/ |
H A D | ViewFsFileStatus.java | 82 public short getReplication() { in getReplication() method in ViewFsFileStatus 83 return myFs.getReplication(); in getReplication()
|
H A D | ViewFsLocatedFileStatus.java | 68 public short getReplication() { in getReplication() method in ViewFsLocatedFileStatus 69 return myFs.getReplication(); in getReplication()
|
/dports/devel/hadoop/hadoop-1.2.1/src/hdfs/org/apache/hadoop/hdfs/server/namenode/ |
H A D | INodeFile.java | 81 public short getReplication() { in getReplication() method in INodeFile 211 return size * getReplication(); in diskspaceConsumed() 231 getReplication(), modificationTime, getPreferredBlockSize(), in toINodeFileUnderConstruction()
|
/dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/tools/distcp2/mapred/ |
H A D | TestCopyMapper.java | 137 System.out.println(fileStatus.getReplication()); in touchFile() 168 Assert.assertEquals(fs.getFileStatus(path).getReplication(), in testRun() 169 fs.getFileStatus(targetPath).getReplication()); in testRun() 681 source.getReplication() != target.getReplication()); in testPreserveBlockSizeAndReplicationImpl() 685 source.getReplication() == target.getReplication()); in testPreserveBlockSizeAndReplicationImpl() 814 source.getReplication() != target.getReplication()); in testPreserveUserGroupImpl()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/ |
H A D | CacheManager.java | 327 short repl = (directive.getReplication() != null) in validateReplication() 328 ? directive.getReplication() : defaultValue; in validateReplication() 493 computeNeeded(directive.getPath(), directive.getReplication()); in addInternal() 563 if (info.getReplication() != null) { in createFromInfoAndDefaults() 564 builder.setReplication(info.getReplication()); in createFromInfoAndDefaults() 626 infoWithDefaults.getReplication()); in modifyDirective() 694 if (filter.getReplication() != null) { in listCacheDirectives() 1022 if (info.getReplication() != null) { in saveState() 1023 b.setReplication(info.getReplication()); in saveState() 1078 p.getPath()).toUri().getPath(), (short) p.getReplication(), p in loadState() [all …]
|
H A D | CachedBlock.java | 104 public short getReplication() { in getReplication() method in CachedBlock 237 append("replication=").append(getReplication()).append(", "). in toString()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/ |
H A D | FileStatus.java | 110 this(other.getLen(), other.isDirectory(), other.getReplication(), in FileStatus() 174 public short getReplication() { in getReplication() method in FileStatus 292 out.writeShort(getReplication()); in write()
|
/dports/devel/hadoop/hadoop-1.2.1/src/tools/org/apache/hadoop/tools/distcp2/util/ |
H A D | DistCpUtils.java | 202 srcFileStatus.getReplication() != targetFileStatus.getReplication()) { in preserve() 203 targetFS.setReplication(path, srcFileStatus.getReplication()); in preserve()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/shell/ |
H A D | Ls.java | 112 (stat.isFile() ? stat.getReplication() : "-"), in processPath() 129 maxRepl = maxLength(maxRepl, stat.getReplication()); in adjustColumnWidths()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-tools/hadoop-distcp/src/test/java/org/apache/hadoop/tools/mapred/ |
H A D | TestCopyMapper.java | 209 System.out.println(fileStatus.getReplication()); in touchFile() 334 Assert.assertEquals(sourceStatus.getReplication(), in verifyCopy() 335 targetStatus.getReplication()); in verifyCopy() 889 source.getReplication() != target.getReplication()); in testPreserveBlockSizeAndReplicationImpl() 893 source.getReplication() == target.getReplication()); in testPreserveBlockSizeAndReplicationImpl() 1023 source.getReplication() != target.getReplication()); in testPreserveUserGroupImpl()
|
/dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/fs/slive/ |
H A D | ConfigExtractor.java | 489 Range<Short> getReplication(String primary) { in getReplication() method in ConfigExtractor 496 Range<Short> getReplication() { in getReplication() method in ConfigExtractor 497 return getReplication(null); in getReplication() 716 LOG.info("Replication amount = " + cfg.getReplication()); in dumpOptions()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/ |
H A D | TestReplaceDatanodeOnFailure.java | 256 Assert.assertEquals(REPLICATION, status.getReplication()); 269 Assert.assertEquals(REPLICATION, status.getReplication()); 312 Assert.assertEquals(REPLICATION, status.getReplication());
|
H A D | TestListPathServlet.java | 199 Assert.assertEquals(expected.getReplication(), computed.getReplication()); in checkFileStatus()
|
/dports/devel/hadoop/hadoop-1.2.1/src/core/org/apache/hadoop/fs/kfs/ |
H A D | KosmosFileSystem.java | 161 kfsImpl.getReplication(srep), in getFileStatus() 253 public short getReplication(Path path) throws IOException { in getReplication() method in KosmosFileSystem 256 return kfsImpl.getReplication(srep); in getReplication()
|
/dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/hdfs/ |
H A D | TestFileStatus.java | 115 assertTrue(status.getReplication() == 1); in testFileStatus() 131 assertTrue(status.getReplication() == 1); in testFileStatus() 184 assertTrue(status.getReplication() == 1); in testFileStatus()
|
H A D | TestListPathServlet.java | 197 Assert.assertEquals(expected.getReplication(), computed.getReplication()); in checkFileStatus()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/test/java/org/apache/hadoop/fs/slive/ |
H A D | ConfigExtractor.java | 515 Range<Short> getReplication(String primary) { in getReplication() method in ConfigExtractor 522 Range<Short> getReplication() { in getReplication() method in ConfigExtractor 523 return getReplication(null); in getReplication() 775 LOG.info("Replication amount = " + cfg.getReplication()); in dumpOptions()
|