/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 | 191 hdfs.mkdirs(sub1); in testRenameFileNotInSnapshot() 212 hdfs.mkdirs(sub1); in testRenameFileInSnapshot() 230 hdfs.mkdirs(sub1); in testRenameTwiceInSnapshot() 274 hdfs.mkdirs(sub1); in testRenameFileInSubDirOfDirWithSnapshot() 275 hdfs.mkdirs(sub2); in testRenameFileInSubDirOfDirWithSnapshot() 300 hdfs.mkdirs(sub1); in testRenameDirectoryInSnapshot() 301 hdfs.mkdirs(sub2); in testRenameDirectoryInSnapshot() 334 hdfs.mkdirs(sdir1); in testRenameDirAcrossSnapshottableDirs() 335 hdfs.mkdirs(sdir2); in testRenameDirAcrossSnapshottableDirs() 1097 hdfs.mkdirs(foo); in testRenameAndUpdateSnapshottableDirs() [all …]
|
H A D | TestXAttrWithSnapshot.java | 82 IOUtils.cleanup(null, hdfs); in shutdown() 122 xattrs = hdfs.getXAttrs(path); in testModifyReadsCurrentState() 128 xattrs = hdfs.getXAttrs(path); in testModifyReadsCurrentState() 137 hdfs.removeXAttr(path, name1); in testModifyReadsCurrentState() 138 hdfs.removeXAttr(path, name2); in testModifyReadsCurrentState() 139 xattrs = hdfs.getXAttrs(path); in testModifyReadsCurrentState() 164 hdfs.removeXAttr(path, name2); in testRemoveReadsCurrentState() 165 xattrs = hdfs.getXAttrs(path); in testRemoveReadsCurrentState() 169 hdfs.removeXAttr(path, name1); in testRemoveReadsCurrentState() 170 xattrs = hdfs.getXAttrs(path); in testRemoveReadsCurrentState() [all …]
|
H A D | TestSnapshotDeletion.java | 131 hdfs.delete(sub, true); in testDeleteDirectoryWithSnapshot() 144 hdfs.mkdirs(bar1); in testApplyEditLogForDeletion() 145 hdfs.mkdirs(bar2); in testApplyEditLogForDeletion() 156 hdfs.delete(foo, true); in testApplyEditLogForDeletion() 164 hdfs.saveNamespace(); in testApplyEditLogForDeletion() 193 hdfs.delete(dir, true); in testDeleteDirectoryWithSnapshot2() 665 hdfs.mkdirs(subDir2); in testCombineSnapshotDiff3() 906 hdfs.mkdirs(path); in testDeleteSnapshotWithPermissionsDisabled() 1067 hdfs.close(); in testHANNRestartAfterSnapshotDeletion() 1082 hdfs.mkdirs(dir); in testHANNRestartAfterSnapshotDeletion() [all …]
|
H A D | TestSnapshottableDirListing.java | 52 DistributedFileSystem hdfs; field in TestSnapshottableDirListing 62 hdfs.mkdirs(dir1); in setUp() 63 hdfs.mkdirs(dir2); in setUp() 86 hdfs.allowSnapshot(root); in testListSnapshottableDir() 98 hdfs.allowSnapshot(dir1); in testListSnapshottableDir() 107 hdfs.allowSnapshot(dir2); in testListSnapshottableDir() 119 hdfs.mkdirs(dir3); in testListSnapshottableDir() 128 hdfs.allowSnapshot(dir2); in testListSnapshottableDir() 145 hdfs.allowSnapshot(sub1); in testListSnapshottableDir() 146 hdfs.allowSnapshot(sub2); in testListSnapshottableDir() [all …]
|
H A D | TestAclWithSnapshot.java | 112 hdfs.setAcl(path, aclSpec); in testOriginalAclEnforcedForSnapshotRootAfterChange() 142 hdfs.setAcl(path, aclSpec); in testOriginalAclEnforcedForSnapshotRootAfterChange() 320 hdfs.removeAcl(path); in testOriginalAclEnforcedForSnapshotRootAfterRemoval() 405 hdfs.removeAcl(filePath); in testOriginalAclEnforcedForSnapshotContentsAfterRemoval() 491 hdfs.removeAcl(path); in testRemoveReadsCurrentState() 586 hdfs.allowSnapshot(path); in testChangeAclExceedsQuota() 621 hdfs.allowSnapshot(path); in testRemoveAclExceedsQuota() 653 hdfs.mkdirs(path); in testGetAclStatusDotSnapshotPath() 667 hdfs.mkdirs(path); in testDeDuplication() 672 hdfs.mkdirs(subdir); in testDeDuplication() [all …]
|
H A D | TestSnapshotDiffReport.java | 112 hdfs.delete(file11, true); in modifyAndCreateSnapshot() 186 hdfs.mkdirs(subsubsub1); in testDiffReport() 223 report = hdfs.getSnapshotDiffReport(hdfs.makeQualified(subsubsub1), "s0", "s2"); in testDiffReport() 344 hdfs.mkdirs(bar); in testDiffReportWithRename() 345 hdfs.mkdirs(sdir2); in testDiffReportWithRename() 352 hdfs.rename(bar, bar2); in testDiffReportWithRename() 356 hdfs.rename(foo, foo2); in testDiffReportWithRename() 440 hdfs.delete(bar, true); in testDiffReportWithRenameAndDelete() 460 hdfs.mkdirs(bar); in testDiffReportWithRenameToNewDir() 484 hdfs.rename(foo, bar); in testDiffReportWithRenameAndAppend() [all …]
|
H A D | TestSnapshotFileLength.java | 40 import org.apache.hadoop.hdfs.DFSTestUtil; 67 hdfs = cluster.getFileSystem(); in setUp() 86 hdfs.mkdirs(sub); in testSnapshotfileLength() 101 hdfs.allowSnapshot(sub); in testSnapshotfileLength() 102 hdfs.createSnapshot(sub, snapshot1); in testSnapshotfileLength() 140 fis = hdfs.open(file1); in testSnapshotfileLength() 146 fis = hdfs.open(file1snap1); in testSnapshotfileLength() 176 hdfs.mkdirs(sub); in testSnapshotFileLengthWithCatCommand() 180 hdfs.allowSnapshot(sub); in testSnapshotFileLengthWithCatCommand() 188 fis = hdfs.open(file1); in testSnapshotFileLengthWithCatCommand() [all …]
|
H A D | TestNestedSnapshots.java | 102 hdfs.allowSnapshot(foo); in testNestedSnapshots() 109 hdfs.allowSnapshot(bar); in testNestedSnapshots() 124 hdfs.allowSnapshot(rootPath); in testNestedSnapshots() 135 hdfs.disallowSnapshot(foo); in testNestedSnapshots() 147 hdfs.allowSnapshot(foo); in testNestedSnapshots() 156 hdfs.mkdirs(sub2Bar); in testNestedSnapshots() 207 hdfs.allowSnapshot(dir); in testSnapshotLimit() 244 hdfs.allowSnapshot(dir); in testSnapshotName() 313 hdfs.mkdirs(sub); 323 hdfs.allowSnapshot(sub); [all …]
|
H A D | TestSnapshotBlocksMap.java | 224 hdfs.mkdirs(foo); in testReadSnapshotFileWithCheckpoint() 225 hdfs.allowSnapshot(foo); in testReadSnapshotFileWithCheckpoint() 251 hdfs.mkdirs(foo); in testReadRenamedSnapshotFileWithCheckpoint() 252 hdfs.mkdirs(foo2); in testReadRenamedSnapshotFileWithCheckpoint() 254 hdfs.allowSnapshot(foo); in testReadRenamedSnapshotFileWithCheckpoint() 293 hdfs.append(bar); in testDeletionWithZeroSizeBlock() 312 hdfs.delete(bar, true); in testDeletionWithZeroSizeBlock() 331 hdfs.append(bar); in testDeletionWithZeroSizeBlock2() 370 hdfs.append(bar); in testDeletionWithZeroSizeBlock3() 384 hdfs.rename(bar, bar2); in testDeletionWithZeroSizeBlock3() [all …]
|
H A D | TestSnapshotMetrics.java | 53 private DistributedFileSystem hdfs; field in TestSnapshotMetrics 62 hdfs = cluster.getFileSystem(); in setUp() 88 hdfs.allowSnapshot(sub1); in testSnapshottableDirs() 95 hdfs.allowSnapshot(sub2); in testSnapshottableDirs() 102 hdfs.allowSnapshot(subsub1); in testSnapshottableDirs() 108 hdfs.allowSnapshot(sub1); in testSnapshottableDirs() 115 hdfs.disallowSnapshot(sub1); in testSnapshottableDirs() 120 hdfs.delete(subsub1, true); in testSnapshottableDirs() 149 hdfs.allowSnapshot(sub1); in testSnapshots() 150 hdfs.createSnapshot(sub1, "s1"); in testSnapshots() [all …]
|
H A D | TestSnapshotRename.java | 33 import org.apache.hadoop.hdfs.DFSTestUtil; 35 import org.apache.hadoop.hdfs.MiniDFSCluster; 67 DistributedFileSystem hdfs; field in TestSnapshotRename 77 hdfs = cluster.getFileSystem(); in setUp() 125 hdfs.renameSnapshot(sub1, "s3", "s22"); in testSnapshotList() 132 hdfs.renameSnapshot(sub1, "s1", "s4"); in testSnapshotList() 151 assertTrue(hdfs.exists(ssPath)); in testSnapshotRename() 155 hdfs.renameSnapshot(sub1, "s1", "s2"); in testSnapshotRename() 157 assertFalse(hdfs.exists(ssPath)); in testSnapshotRename() 162 assertTrue(hdfs.exists(ssPath)); in testSnapshotRename() [all …]
|
H A D | TestSetQuotaWithSnapshot.java | 29 import org.apache.hadoop.hdfs.DFSConfigKeys; 30 import org.apache.hadoop.hdfs.DFSTestUtil; 31 import org.apache.hadoop.hdfs.DFSUtil; 57 protected DistributedFileSystem hdfs; field in TestSetQuotaWithSnapshot 72 hdfs = cluster.getFileSystem(); in setUp() 85 hdfs.mkdirs(dir); in testSetQuota() 90 hdfs.mkdirs(sub); in testSetQuota() 110 hdfs.mkdirs(dir); in testClearQuota() 112 hdfs.allowSnapshot(dir); in testClearQuota() 144 hdfs.mkdirs(subDir); in testClearQuota() [all …]
|
H A D | TestINodeFileUnderConstructionWithSnapshot.java | 35 import org.apache.hadoop.hdfs.DFSConfigKeys; 36 import org.apache.hadoop.hdfs.DFSTestUtil; 72 DistributedFileSystem hdfs; field in TestINodeFileUnderConstructionWithSnapshot 84 hdfs = cluster.getFileSystem(); in setUp() 85 hdfs.mkdirs(dir); in setUp() 109 hdfs.createSnapshot(dir, "s1"); in testSnapshotAfterAppending() 119 hdfs.createSnapshot(dir, "s2"); in testSnapshotAfterAppending() 169 hdfs.createSnapshot(dir, "s1"); in testSnapshotWhileAppending() 184 hdfs.createSnapshot(dir, "s2"); in testSnapshotWhileAppending() 216 status = hdfs.getFileStatus(file); in testGetBlockLocations() [all …]
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/fs/permission/ |
H A D | TestStickyBit.java | 84 if (hdfs != null) { in setup() 155 hdfs.mkdirs(p2); in confirmStickyBitDoesntPropagate() 180 writeFile(hdfs, f); in confirmSettingAndGetting() 198 hdfs.mkdirs(p); in testGeneralSBBehavior() 207 hdfs.mkdirs(p); in testGeneralSBBehavior() 213 hdfs.mkdirs(p); in testGeneralSBBehavior() 234 hdfs.mkdirs(p); in testAclGeneralSBBehavior() 243 hdfs.mkdirs(p); in testAclGeneralSBBehavior() 250 hdfs.mkdirs(p); in testAclGeneralSBBehavior() 322 hdfs.mkdirs(p); in testStickyBitPersistence() [all …]
|
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/python/pyarrow/tests/ |
H A D | test_hdfs.py | 55 @pytest.mark.hdfs 60 hdfs.mkdir(base_path) 79 cls.hdfs.close() 124 self.hdfs.mkdir(path) 151 self.hdfs.mkdir(path) 197 self.hdfs.mkdir(path) 198 self.hdfs.mkdir(subdir) 305 self.hdfs.mkdir(tmpdir) 322 self.hdfs.mkdir(tmpdir) 397 hdfs = None [all …]
|
/dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/python/pyarrow/tests/ |
H A D | test_hdfs.py | 52 @pytest.mark.hdfs 57 hdfs.mkdir(base_path) 76 cls.hdfs.close() 121 self.hdfs.mkdir(path) 148 self.hdfs.mkdir(path) 194 self.hdfs.mkdir(path) 195 self.hdfs.mkdir(subdir) 302 self.hdfs.mkdir(tmpdir) 319 self.hdfs.mkdir(tmpdir) 392 hdfs = None [all …]
|
/dports/databases/arrow/apache-arrow-6.0.1/python/pyarrow/tests/ |
H A D | test_hdfs.py | 64 @pytest.mark.hdfs 69 hdfs.mkdir(base_path) 88 cls.hdfs.close() 133 self.hdfs.mkdir(path) 160 self.hdfs.mkdir(path) 206 self.hdfs.mkdir(path) 207 self.hdfs.mkdir(subdir) 315 self.hdfs.mkdir(tmpdir) 332 self.hdfs.mkdir(tmpdir) 402 hdfs = None [all …]
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/namenode/ |
H A D | TestFSImageWithSnapshot.java | 76 DistributedFileSystem hdfs; field in TestFSImageWithSnapshot 187 hdfs.saveNamespace(); in testSnapshotOnRoot() 214 hdfs.saveNamespace(); in testSnapshotOnRoot() 239 hdfs.mkdirs(dir); in testSaveLoadImage() 242 hdfs.mkdirs(sub1); in testSaveLoadImage() 245 hdfs.mkdirs(sub11); in testSaveLoadImage() 408 hdfs.saveNamespace(); in testLoadImageWithAppending() 432 hdfs.saveNamespace(); in testLoadImageWithEmptyFile() 472 hdfs.mkdirs(subsubDir); in testSaveLoadImageAfterSnapshotDeletion() 480 hdfs.mkdirs(newDir); in testSaveLoadImageAfterSnapshotDeletion() [all …]
|
H A D | TestFSImage.java | 18 package org.apache.hadoop.hdfs.server.namenode; 34 import org.apache.hadoop.hdfs.DFSConfigKeys; 35 import org.apache.hadoop.hdfs.DFSOutputStream; 37 import org.apache.hadoop.hdfs.HdfsConfiguration; 38 import org.apache.hadoop.hdfs.MiniDFSCluster; 46 import org.apache.hadoop.hdfs.util.MD5FileUtils; 163 hdfs.createNewFile(file); in testLoadMtimeAtime() 164 hdfs.mkdirs(dir); in testLoadMtimeAtime() 165 hdfs.createSymlink(file, link, false); in testLoadMtimeAtime() 175 hdfs.saveNamespace(); in testLoadMtimeAtime() [all …]
|
/dports/devel/py-dask/dask-2021.11.2/dask/bytes/tests/ |
H A D | test_hdfs.py | 38 def hdfs(request): function 42 if hdfs.exists(basedir): 44 hdfs.mkdir(basedir) 46 yield hdfs 48 if hdfs.exists(basedir): 56 def test_read_bytes(hdfs): argument 71 def test_read_bytes_URL(hdfs): argument 123 def test_open_files_write(hdfs): argument 138 def test_read_csv(hdfs): argument 153 def test_read_text(hdfs): argument [all …]
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/ |
H A D | DNConf.java | 18 package org.apache.hadoop.hdfs.server.datanode; 23 import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_BLOCKREPORT_INITIAL_DELAY_KEY; 30 import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_CLIENT_SOCKET_TIMEOUT_KEY; 37 import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_DATANODE_SYNCONCLOSE_KEY; 42 import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_HEARTBEAT_INTERVAL_DEFAULT; 43 import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_HEARTBEAT_INTERVAL_KEY; 46 import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_ENCRYPT_DATA_TRANSFER_KEY; 57 import org.apache.hadoop.hdfs.DFSConfigKeys; 58 import org.apache.hadoop.hdfs.protocol.datatransfer.TrustedChannelResolver; 59 import org.apache.hadoop.hdfs.protocol.datatransfer.sasl.DataTransferSaslUtil; [all …]
|
/dports/databases/tiledb/TileDB-2.5.2/test/src/ |
H A D | unit-hdfs-filesystem.cc | 45 using namespace tiledb::sm::hdfs; 49 HDFS hdfs; variable 51 Status st = hdfs.init(config); 62 st = hdfs.create_dir(URI("hdfs:///tiledb_test")); 68 st = hdfs.create_dir(URI("hdfs:///tiledb_test")); 71 st = hdfs.touch(URI("hdfs:///tiledb_test_file")); 89 st = hdfs.write( 94 st = hdfs.read( 107 st = hdfs.read( 121 st = hdfs.ls(URI("hdfs:///"), &paths); [all …]
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/qjournal/protocolPB/ |
H A D | QJournalProtocolServerSideTranslatorPB.java | 18 package org.apache.hadoop.hdfs.qjournal.protocolPB; 24 import org.apache.hadoop.hdfs.protocol.HdfsConstants; 25 import org.apache.hadoop.hdfs.protocolPB.JournalProtocolPB; 26 import org.apache.hadoop.hdfs.protocolPB.PBHelper; 27 import org.apache.hadoop.hdfs.qjournal.protocol.QJournalProtocol; 28 import org.apache.hadoop.hdfs.qjournal.protocol.QJournalProtocolProtos; 68 import org.apache.hadoop.hdfs.qjournal.protocol.RequestInfo; 69 import org.apache.hadoop.hdfs.server.common.HdfsServerConstants.NodeType; 70 import org.apache.hadoop.hdfs.server.common.StorageInfo; 71 import org.apache.hadoop.hdfs.server.namenode.NameNodeLayoutVersion; [all …]
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/protocolPB/ |
H A D | ClientNamenodeProtocolServerSideTranslatorPB.java | 18 package org.apache.hadoop.hdfs.protocolPB; 31 import org.apache.hadoop.hdfs.protocol.BlockStoragePolicy; 33 import org.apache.hadoop.hdfs.protocol.CacheDirectiveInfo; 34 import org.apache.hadoop.hdfs.protocol.CachePoolEntry; 35 import org.apache.hadoop.hdfs.protocol.ClientProtocol; 36 import org.apache.hadoop.hdfs.protocol.CorruptFileBlocks; 37 import org.apache.hadoop.hdfs.protocol.DirectoryListing; 38 import org.apache.hadoop.hdfs.protocol.EncryptionZone; 39 import org.apache.hadoop.hdfs.protocol.HdfsFileStatus; 41 import org.apache.hadoop.hdfs.protocol.LocatedBlock; [all …]
|
H A D | NamenodeProtocolServerSideTranslatorPB.java | 18 package org.apache.hadoop.hdfs.protocolPB; 22 import org.apache.hadoop.hdfs.protocol.DatanodeInfo; 25 import org.apache.hadoop.hdfs.protocol.proto.NamenodeProtocolProtos; 48 import org.apache.hadoop.hdfs.security.token.block.ExportedBlockKeys; 49 import org.apache.hadoop.hdfs.server.namenode.CheckpointSignature; 50 import org.apache.hadoop.hdfs.server.protocol.BlocksWithLocations; 51 import org.apache.hadoop.hdfs.server.protocol.NamenodeCommand; 52 import org.apache.hadoop.hdfs.server.protocol.NamenodeProtocol; 53 import org.apache.hadoop.hdfs.server.protocol.NamenodeRegistration; 54 import org.apache.hadoop.hdfs.server.protocol.NamespaceInfo; [all …]
|