/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/web/ |
H A D | TestWebHdfsWithMultipleNameNodes.java | 58 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 D | TestWebHdfsUrl.java | 67 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 D | TestWebHdfsFileSystemContract.java | 163 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 D | WebHdfsTestUtil.java | 83 public static URL toUrl(final WebHdfsFileSystem webhdfs, 86 final URL url = webhdfs.toUrl(op, fspath, parameters);
|
H A D | TestFSMainOperationsWebHdfs.java | 175 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 D | TestWebHdfsFileSystemContract.java | 165 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 D | WebHdfsTestUtil.java | 67 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 D | TestWebHdfsUrl.java | 64 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 D | TestDelegationTokenForProxyUser.java | 166 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 D | TestDelegationToken.java | 189 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 D | TestDelegationTokenForProxyUser.java | 153 …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 D | TestDelegationToken.java | 179 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 D | TestOfflineImageViewerForAcl.java | 170 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 D | TestOfflineImageViewer.java | 283 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 D | RegistryTestHelper.java | 142 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 D | URLDispatcher.java | 25 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 D | FSImageHandler.java | 52 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 D | ExceptionHandler.java | 18 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 D | ParameterParser.java | 18 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 D | DataNodeUGIProvider.java | 14 package org.apache.hadoop.hdfs.server.datanode.web.webhdfs;
|
H A D | HdfsWriter.java | 18 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 D | TokenAspect.java | 176 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 D | TestSymlinkHdfs.java | 54 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 D | TestDistributedFileSystem.java | 364 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 D | TestParameterParser.java | 18 package org.apache.hadoop.hdfs.server.datanode.web.webhdfs;
|