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

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

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

WebHdfsFileSystem.isEnabled介绍

[英]Is WebHDFS enabled in conf?
[中]是否在conf中启用WebHDFS?

代码示例

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

private void initWebHdfs(Configuration conf) throws IOException {
 if (WebHdfsFileSystem.isEnabled(conf, HttpServer2.LOG)) {
  // set user pattern based on configuration file
  UserParam.setUserPattern(conf.get(
    DFSConfigKeys.DFS_WEBHDFS_USER_PATTERN_KEY,
    DFSConfigKeys.DFS_WEBHDFS_USER_PATTERN_DEFAULT));
  // add authentication filter for webhdfs
  final String className = conf.get(
    DFSConfigKeys.DFS_WEBHDFS_AUTHENTICATION_FILTER_KEY,
    DFSConfigKeys.DFS_WEBHDFS_AUTHENTICATION_FILTER_DEFAULT);
  final String name = className;
  final String pathSpec = WebHdfsFileSystem.PATH_PREFIX + "/*";
  Map<String, String> params = getAuthFilterParams(conf);
  HttpServer2.defineFilter(httpServer.getWebAppContext(), name, className,
    params, new String[] { pathSpec });
  HttpServer2.LOG.info("Added filter '" + name + "' (class=" + className
    + ")");
  // add webhdfs packages
  httpServer.addJerseyResourcePackage(NamenodeWebHdfsMethods.class
    .getPackage().getName() + ";" + Param.class.getPackage().getName(),
    pathSpec);
 }
}

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

private void initWebHdfs(Configuration conf) throws IOException {
 if (WebHdfsFileSystem.isEnabled(conf, HttpServer2.LOG)) {
  // set user pattern based on configuration file
  UserParam.setUserPattern(conf.get(
    DFSConfigKeys.DFS_WEBHDFS_USER_PATTERN_KEY,
    DFSConfigKeys.DFS_WEBHDFS_USER_PATTERN_DEFAULT));
  // add authentication filter for webhdfs
  final String className = conf.get(
    DFSConfigKeys.DFS_WEBHDFS_AUTHENTICATION_FILTER_KEY,
    DFSConfigKeys.DFS_WEBHDFS_AUTHENTICATION_FILTER_DEFAULT);
  final String name = className;
  final String pathSpec = WebHdfsFileSystem.PATH_PREFIX + "/*";
  Map<String, String> params = getAuthFilterParams(conf);
  HttpServer2.defineFilter(httpServer.getWebAppContext(), name, className,
    params, new String[] { pathSpec });
  HttpServer2.LOG.info("Added filter '" + name + "' (class=" + className
    + ")");
  // add webhdfs packages
  httpServer.addJerseyResourcePackage(NamenodeWebHdfsMethods.class
    .getPackage().getName() + ";" + Param.class.getPackage().getName(),
    pathSpec);
 }
}

代码示例来源:origin: io.fabric8/fabric-hadoop

DataBlockScanner.Servlet.class);
if (WebHdfsFileSystem.isEnabled(conf, LOG)) {
 infoServer.addJerseyResourcePackage(DatanodeWebHdfsMethods.class
   .getPackage().getName() + ";" + Param.class.getPackage().getName(),

相关文章

微信公众号

最新文章

更多