org.apache.hadoop.hdfs.web.WebHdfsFileSystem.getCurrentNNAddr()方法的使用及代码示例

x33g5p2x  于2022-02-03 转载在 其他  
字(1.9k)|赞(0)|评价(0)|浏览(80)

本文整理了Java中org.apache.hadoop.hdfs.web.WebHdfsFileSystem.getCurrentNNAddr()方法的一些代码示例,展示了WebHdfsFileSystem.getCurrentNNAddr()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。WebHdfsFileSystem.getCurrentNNAddr()方法的具体详情如下:
包路径:org.apache.hadoop.hdfs.web.WebHdfsFileSystem
类名称:WebHdfsFileSystem
方法名:getCurrentNNAddr

WebHdfsFileSystem.getCurrentNNAddr介绍

暂无

代码示例

代码示例来源:origin: org.apache.hadoop/hadoop-hdfs-client

/**
 * Return a URL pointing to given path on the namenode.
 *
 * @param path to obtain the URL for
 * @param query string to append to the path
 * @return namenode URL referring to the given path
 * @throws IOException on error constructing the URL
 */
private URL getNamenodeURL(String path, String query) throws IOException {
 InetSocketAddress nnAddr = getCurrentNNAddr();
 final URL url = new URL(getTransportScheme(), nnAddr.getHostName(),
   nnAddr.getPort(), path + '?' + query);
 LOG.trace("url={}", url);
 return url;
}

代码示例来源:origin: ch.cern.hadoop/hadoop-hdfs

/**
 * Return a URL pointing to given path on the namenode.
 *
 * @param path to obtain the URL for
 * @param query string to append to the path
 * @return namenode URL referring to the given path
 * @throws IOException on error constructing the URL
 */
private URL getNamenodeURL(String path, String query) throws IOException {
 InetSocketAddress nnAddr = getCurrentNNAddr();
 final URL url = new URL(getTransportScheme(), nnAddr.getHostName(),
    nnAddr.getPort(), path + '?' + query);
 if (LOG.isTraceEnabled()) {
  LOG.trace("url=" + url);
 }
 return url;
}

代码示例来源:origin: io.prestosql.hadoop/hadoop-apache

/**
 * Return a URL pointing to given path on the namenode.
 *
 * @param path to obtain the URL for
 * @param query string to append to the path
 * @return namenode URL referring to the given path
 * @throws IOException on error constructing the URL
 */
private URL getNamenodeURL(String path, String query) throws IOException {
 InetSocketAddress nnAddr = getCurrentNNAddr();
 final URL url = new URL(getTransportScheme(), nnAddr.getHostName(),
    nnAddr.getPort(), path + '?' + query);
 if (LOG.isTraceEnabled()) {
  LOG.trace("url=" + url);
 }
 return url;
}

相关文章

微信公众号

最新文章

更多