Home
last modified time | relevance | path

Searched refs:webhdfs (Results 1 – 25 of 40) sorted by relevance

12

/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/web/
H A DTestWebHdfsWithMultipleNameNodes.java58 private static WebHdfsFileSystem[] webhdfs; field in TestWebHdfsWithMultipleNameNodes
82 webhdfs = new WebHdfsFileSystem[nNameNodes]; in setupCluster()
83 for(int i = 0; i < webhdfs.length; i++) { in setupCluster()
107 for(int i = 0; i < webhdfs.length; i++) { in createStrings()
124 for(int i = 0; i < webhdfs.length; i++) { in testRedirect()
130 for(int i = 0; i < webhdfs.length; i++) { in testRedirect()
137 for(int i = 0; i < webhdfs.length; i++) { in testRedirect()
138 final FSDataInputStream in = webhdfs[i].open(p); in testRedirect()
146 for(int i = 0; i < webhdfs.length; i++) { in testRedirect()
152 for(int i = 0; i < webhdfs.length; i++) { in testRedirect()
[all …]
H A DTestWebHdfsUrl.java67 final WebHdfsFileSystem webhdfs = (WebHdfsFileSystem) FileSystem.get( in testEncodedPathUrl() local
73 URL encodedPathUrl = webhdfs.toUrl(PutOpParam.Op.CREATE, fsPath); in testEncodedPathUrl()
87 WebHdfsFileSystem webhdfs = getWebHdfsFileSystem(ugi, conf); in testSimpleAuthParamsInUrl() local
109 WebHdfsFileSystem webhdfs = getWebHdfsFileSystem(ugi, conf); in testSimpleProxyAuthParamsInUrl() local
135 WebHdfsFileSystem webhdfs = getWebHdfsFileSystem(ugi, conf); in testSecureAuthParamsInUrl() local
180 webhdfs.setDelegationToken(null); in testSecureAuthParamsInUrl()
183 cancelTokenUrl = webhdfs.toUrl(PutOpParam.Op.CANCELDELEGATIONTOKEN, in testSecureAuthParamsInUrl()
216 WebHdfsFileSystem webhdfs = getWebHdfsFileSystem(ugi, conf); in testSecureProxyAuthParamsInUrl() local
264 webhdfs.setDelegationToken(null); in testSecureProxyAuthParamsInUrl()
297 WebHdfsFileSystem webhdfs = getWebHdfsFileSystem(ugi, conf); in testCheckAccessUrl() local
[all …]
H A DTestWebHdfsFileSystemContract.java163 final URL url = webhdfs.toUrl(op, p); in testCaseInsensitive()
295 WebHdfsFileSystem webhdfs = (WebHdfsFileSystem)fs; in testLengthParamLongerThanFile() local
297 assertTrue(webhdfs.mkdirs(dir)); in testLengthParamLongerThanFile()
344 WebHdfsFileSystem webhdfs = (WebHdfsFileSystem)fs; in testOffsetPlusLengthParamsLongerThanFile() local
346 assertTrue(webhdfs.mkdirs(dir)); in testOffsetPlusLengthParamsLongerThanFile()
393 assertTrue(webhdfs.mkdirs(dir)); in testResponseCode()
428 final URL url = webhdfs.toUrl(op, dir); in testResponseCode()
449 final URL url = webhdfs.toUrl(op, dir); in testResponseCode()
466 final URL url = webhdfs.toUrl(op, dir); in testResponseCode()
492 final URL url = webhdfs.toUrl(op, file); in testResponseCode()
[all …]
H A DWebHdfsTestUtil.java83 public static URL toUrl(final WebHdfsFileSystem webhdfs,
86 final URL url = webhdfs.toUrl(op, fspath, parameters);
H A DTestFSMainOperationsWebHdfs.java175 final WebHdfsFileSystem webhdfs = (WebHdfsFileSystem)fileSystem; in testJsonParseClosesInputStream() local
179 final URL url = webhdfs.toUrl(op, file); in testJsonParseClosesInputStream()
/dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/hdfs/web/
H A DTestWebHdfsFileSystemContract.java165 final WebHdfsFileSystem webhdfs = (WebHdfsFileSystem)fs; in testCaseInsensitive() local
169 final URL url = webhdfs.toUrl(op, p); in testCaseInsensitive()
264 final WebHdfsFileSystem webhdfs = (WebHdfsFileSystem)fs; in testRootDir() local
265 final URL url = webhdfs.toUrl(GetOpParam.Op.NULL, root); in testRootDir()
298 final WebHdfsFileSystem webhdfs = (WebHdfsFileSystem)fs; in testResponseCode() local
301 assertTrue(webhdfs.mkdirs(dir)); in testResponseCode()
303 final FSDataOutputStream out = webhdfs.create(file); in testResponseCode()
336 final URL url = webhdfs.toUrl(op, dir); in testResponseCode()
342 assertFalse(webhdfs.setReplication(dir, (short)1)); in testResponseCode()
357 final URL url = webhdfs.toUrl(op, dir); in testResponseCode()
[all …]
H A DWebHdfsTestUtil.java67 public static URL toUrl(final WebHdfsFileSystem webhdfs,
70 final URL url = webhdfs.toUrl(op, fspath, parameters);
82 public static HttpURLConnection twoStepWrite(final WebHdfsFileSystem webhdfs,
84 return webhdfs.new Runner(op, conn).twoStepWrite();
87 public static FSDataOutputStream write(final WebHdfsFileSystem webhdfs,
90 return webhdfs.write(op, conn, bufferSize);
H A DTestWebHdfsUrl.java64 final WebHdfsFileSystem webhdfs = (WebHdfsFileSystem) FileSystem.get( in testDelegationTokenInUrl() local
68 URL renewTokenUrl = webhdfs.toUrl(PutOpParam.Op.RENEWDELEGATIONTOKEN, in testDelegationTokenInUrl()
70 URL cancelTokenUrl = webhdfs.toUrl(PutOpParam.Op.CANCELDELEGATIONTOKEN, in testDelegationTokenInUrl()
/dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/hdfs/security/
H A DTestDelegationTokenForProxyUser.java166 final WebHdfsFileSystem webhdfs = WebHdfsTestUtil.getWebHdfsFileSystemAs(ugi, config); in testWebHdfsDoAs() local
173 final URL url = WebHdfsTestUtil.toUrl(webhdfs, in testWebHdfsDoAs()
186 final URL url = WebHdfsTestUtil.toUrl(webhdfs, in testWebHdfsDoAs()
206 final URL url = WebHdfsTestUtil.toUrl(webhdfs, op, f, new DoAsParam(PROXY_USER)); in testWebHdfsDoAs()
209 conn = WebHdfsTestUtil.twoStepWrite(webhdfs, op, conn); in testWebHdfsDoAs()
210 final FSDataOutputStream out = WebHdfsTestUtil.write(webhdfs, op, conn, 4096); in testWebHdfsDoAs()
214 final FileStatus status = webhdfs.getFileStatus(f); in testWebHdfsDoAs()
222 final URL url = WebHdfsTestUtil.toUrl(webhdfs, op, f, new DoAsParam(PROXY_USER)); in testWebHdfsDoAs()
224 conn = WebHdfsTestUtil.twoStepWrite(webhdfs, op, conn); in testWebHdfsDoAs()
225 final FSDataOutputStream out = WebHdfsTestUtil.write(webhdfs, op, conn, 4096); in testWebHdfsDoAs()
[all …]
H A DTestDelegationToken.java189 final WebHdfsFileSystem webhdfs = ugi.doAs( in testDelegationTokenWebHdfsApi() local
197 final Token<DelegationTokenIdentifier> token = webhdfs in testDelegationTokenWebHdfsApi()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/security/
H A DTestDelegationTokenForProxyUser.java153 …final WebHdfsFileSystem webhdfs = WebHdfsTestUtil.getWebHdfsFileSystemAs(ugi, config, WebHdfsFileS… in testWebHdfsDoAs() local
158 Whitebox.setInternalState(webhdfs, "ugi", proxyUgi); in testWebHdfsDoAs()
161 Path responsePath = webhdfs.getHomeDirectory(); in testWebHdfsDoAs()
163 Assert.assertEquals(webhdfs.getUri() + "/user/" + PROXY_USER, responsePath.toString()); in testWebHdfsDoAs()
168 FSDataOutputStream out = webhdfs.create(f); in testWebHdfsDoAs()
172 final FileStatus status = webhdfs.getFileStatus(f); in testWebHdfsDoAs()
178 final FSDataOutputStream out = webhdfs.append(f); in testWebHdfsDoAs()
182 final FileStatus status = webhdfs.getFileStatus(f); in testWebHdfsDoAs()
H A DTestDelegationToken.java179 final WebHdfsFileSystem webhdfs = ugi.doAs( in testDelegationTokenWebHdfsApi() local
189 final Token<?> tokens[] = webhdfs.addDelegationTokens("JobTracker", creds); in testDelegationTokenWebHdfsApi()
194 final Token<?> tokens2[] = webhdfs.addDelegationTokens("JobTracker", creds); in testDelegationTokenWebHdfsApi()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/tools/offlineImageViewer/
H A DTestOfflineImageViewerForAcl.java170 WebHdfsFileSystem webhdfs = (WebHdfsFileSystem)FileSystem.get(uri, conf); in testWebImageViewerForAcl() local
173 AclStatus acl = webhdfs.getAclStatus(new Path("/dirWithNoAcl")); in testWebImageViewerForAcl()
177 acl = webhdfs.getAclStatus(new Path("/dirWithDefaultAcl")); in testWebImageViewerForAcl()
181 acl = webhdfs.getAclStatus(new Path("/noAcl")); in testWebImageViewerForAcl()
185 acl = webhdfs.getAclStatus(new Path("/withAcl")); in testWebImageViewerForAcl()
189 acl = webhdfs.getAclStatus(new Path("/withSeveralAcls")); in testWebImageViewerForAcl()
H A DTestOfflineImageViewer.java283 WebHdfsFileSystem webhdfs = (WebHdfsFileSystem)FileSystem.get(uri, conf); in testWebImageViewer() local
286 FileStatus[] statuses = webhdfs.listStatus(new Path("/")); in testWebImageViewer()
290 statuses = webhdfs.listStatus(new Path("/dir0")); in testWebImageViewer()
294 FileStatus status = webhdfs.listStatus(new Path("/dir0/file0"))[0]; in testWebImageViewer()
299 statuses = webhdfs.listStatus(new Path("/emptydir")); in testWebImageViewer()
312 status = webhdfs.getFileStatus(new Path("/dir0/file0")); in testWebImageViewer()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-registry/src/test/java/org/apache/hadoop/registry/
H A DRegistryTestHelper.java142 Endpoint webhdfs = findEndpoint(record, API_WEBHDFS, true, 1, 1); in validateEntry() local
143 assertEquals(API_WEBHDFS, webhdfs.api); in validateEntry()
144 assertEquals(AddressTypes.ADDRESS_URI, webhdfs.addressType); in validateEntry()
145 assertEquals(ProtocolTypes.PROTOCOL_REST, webhdfs.protocolType); in validateEntry()
146 List<Map<String, String>> addressList = webhdfs.addresses; in validateEntry()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/web/
H A DURLDispatcher.java25 import org.apache.hadoop.hdfs.server.datanode.web.webhdfs.WebHdfsHandler;
30 import static org.apache.hadoop.hdfs.server.datanode.web.webhdfs.WebHdfsHandler.WEBHDFS_PREFIX;
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/tools/offlineImageViewer/
H A DFSImageHandler.java52 import static org.apache.hadoop.hdfs.server.datanode.web.webhdfs.WebHdfsHandler.APPLICATION_JSON_UT…
53 import static org.apache.hadoop.hdfs.server.datanode.web.webhdfs.WebHdfsHandler.WEBHDFS_PREFIX;
54 import static org.apache.hadoop.hdfs.server.datanode.web.webhdfs.WebHdfsHandler.WEBHDFS_PREFIX_LENG…
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/web/webhdfs/
H A DExceptionHandler.java18 package org.apache.hadoop.hdfs.server.datanode.web.webhdfs;
43 import static org.apache.hadoop.hdfs.server.datanode.web.webhdfs.WebHdfsHandler.APPLICATION_JSON_UT…
H A DParameterParser.java18 package org.apache.hadoop.hdfs.server.datanode.web.webhdfs;
48 import static org.apache.hadoop.hdfs.server.datanode.web.webhdfs.WebHdfsHandler.WEBHDFS_PREFIX_LENG…
H A DDataNodeUGIProvider.java14 package org.apache.hadoop.hdfs.server.datanode.web.webhdfs;
H A DHdfsWriter.java18 package org.apache.hadoop.hdfs.server.datanode.web.webhdfs;
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/web/
H A DTokenAspect.java176 private synchronized void addRenewAction(final T webhdfs) { in addRenewAction() argument
181 action = dtRenewer.addRenewAction(webhdfs); in addRenewAction()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/fs/
H A DTestSymlinkHdfs.java54 protected static WebHdfsFileSystem webhdfs; field in TestSymlinkHdfs
92 webhdfs = WebHdfsTestUtil.getWebHdfsFileSystem(conf, WebHdfsFileSystem.SCHEME); in beforeClassSetup()
311 webhdfs.createSymlink(file, link, false); in testWebHDFS()
/dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/hdfs/
H A DTestDistributedFileSystem.java364 final FileSystem webhdfs = ugi.doAs( in testFileChecksum() local
406 final FileChecksum webhdfsfoocs = webhdfs.getFileChecksum(foo); in testFileChecksum()
410 final FileChecksum webhdfs_qfoocs = webhdfs.getFileChecksum(webhdfsqualified); in testFileChecksum()
455 webhdfs.getFileChecksum(webhdfsqualified); in testFileChecksum()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/web/webhdfs/
H A DTestParameterParser.java18 package org.apache.hadoop.hdfs.server.datanode.web.webhdfs;

12