Home
last modified time | relevance | path

Searched refs:hdfs (Results 1 – 25 of 1922) sorted by relevance

12345678910>>...77

/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.java191 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 DTestXAttrWithSnapshot.java82 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 DTestSnapshotDeletion.java131 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 DTestSnapshottableDirListing.java52 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 DTestAclWithSnapshot.java112 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 DTestSnapshotDiffReport.java112 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 DTestSnapshotFileLength.java40 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 DTestNestedSnapshots.java102 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 DTestSnapshotBlocksMap.java224 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 DTestSnapshotMetrics.java53 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 DTestSnapshotRename.java33 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 DTestSetQuotaWithSnapshot.java29 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 DTestINodeFileUnderConstructionWithSnapshot.java35 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 DTestStickyBit.java84 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 Dtest_hdfs.py55 @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 Dtest_hdfs.py52 @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 Dtest_hdfs.py64 @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 DTestFSImageWithSnapshot.java76 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 DTestFSImage.java18 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 Dtest_hdfs.py38 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 DDNConf.java18 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 Dunit-hdfs-filesystem.cc45 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 DQJournalProtocolServerSideTranslatorPB.java18 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 DClientNamenodeProtocolServerSideTranslatorPB.java18 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 DNamenodeProtocolServerSideTranslatorPB.java18 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 …]

12345678910>>...77