Home
last modified time | relevance | path

Searched refs:getReplication (Results 1 – 25 of 125) sorted by relevance

12345

/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-tools/hadoop-distcp/src/test/java/org/apache/hadoop/tools/util/
H A DTestDistCpUtils.java171 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 DCacheReplicationMonitor.java378 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 DCacheDirectiveInfo.java69 this.replication = directive.getReplication(); in Builder()
285 public Short getReplication() { in getReplication() method in CacheDirectiveInfo
314 append(getReplication(), other.getReplication()). in equals()
H A DHdfsFileStatus.java134 public final short getReplication() { in getReplication() method in HdfsFileStatus
263 return new FileStatus(getLen(), isDir(), getReplication(), in makeQualified()
H A DSnapshottableDirectoryStatus.java130 maxRepl = maxLength(maxRepl, status.dirStatus.getReplication()); in print()
155 status.dirStatus.getReplication(), in print()
H A DCacheDirective.java59 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 DTestSymlinkHdfs.java252 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 DTestRenameWithSnapshots.java369 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 DViewFsFileStatus.java82 public short getReplication() { in getReplication() method in ViewFsFileStatus
83 return myFs.getReplication(); in getReplication()
H A DViewFsLocatedFileStatus.java68 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 DINodeFile.java81 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 DTestCopyMapper.java137 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 DCacheManager.java327 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 DCachedBlock.java104 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 DFileStatus.java110 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 DDistCpUtils.java202 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 DLs.java112 (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 DTestCopyMapper.java209 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 DConfigExtractor.java489 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 DTestReplaceDatanodeOnFailure.java256 Assert.assertEquals(REPLICATION, status.getReplication());
269 Assert.assertEquals(REPLICATION, status.getReplication());
312 Assert.assertEquals(REPLICATION, status.getReplication());
H A DTestListPathServlet.java199 Assert.assertEquals(expected.getReplication(), computed.getReplication()); in checkFileStatus()
/dports/devel/hadoop/hadoop-1.2.1/src/core/org/apache/hadoop/fs/kfs/
H A DKosmosFileSystem.java161 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 DTestFileStatus.java115 assertTrue(status.getReplication() == 1); in testFileStatus()
131 assertTrue(status.getReplication() == 1); in testFileStatus()
184 assertTrue(status.getReplication() == 1); in testFileStatus()
H A DTestListPathServlet.java197 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 DConfigExtractor.java515 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()

12345