メソッドの詳細

• withResources

  ResourceConfigurer<HadoopConfigConfigurer> withResources()
                                                           throws java.lang.Exception

  ResourceConfigurer を使用して、構成オプションをリソースプロパティとして指定します。
  
  JavaConfig:
  

   public void configure(HadoopConfigConfigurer config) throws Exception {
     Properties props = new Properties();
     config
       .withResources()
         .resource("cfg-1.properties")
         .resource("cfg-2.properties")
         .and();
   }
   

  
  XML:
  

   <hadoop:configuration properties-location="cfg-1.properties, cfg-2.properties"/>
   

  戻り値:

  連鎖用 ResourceConfigurer

  例外:

  java.lang.Exception - エラーが発生した場合

• withProperties

  PropertiesConfigurer<HadoopConfigConfigurer> withProperties()
                                                              throws java.lang.Exception

  PropertiesConfigurer を使用して、構成オプションをプロパティとして指定します。
  
  JavaConfig:
  

   public void configure(HadoopConfigConfigurer config) throws Exception {
     Properties props = new Properties();
     config
       .withProperties()
         .properties(props)
         .property("myKey1", ",myValue1")
         .and();
   }
   

  
  XML:
  

   <util:properties id="props" location="props.properties"/>
     <prop key="myKey1">myValue1</prop>
   </util:properties>
   <hadoop:configuration properties-ref="props"/>
   

  戻り値:

  連鎖用 PropertiesConfigurer

  例外:

  java.lang.Exception - エラーが発生した場合

• withSecurity

  SecurityConfigurer<HadoopConfigConfigurer> withSecurity()
                                                          throws java.lang.Exception

  SecurityConfigurer を使用してセキュリティオプションを指定します。

  JavaConfig:

   public void configure(HadoopConfigConfigurer config) throws Exception {
     config
       .withSecurity()
         .authMethod("kerberos")
         .namenodePrincipal("hdfs/myhost@LOCALDOMAIN")
         .rmManagerPrincipal("yarn/myhost@LOCALDOMAIN");
   }
   

  XML:

  同等のものはありません

  戻り値:

  連鎖用 SecurityConfigurer

  例外:

  java.lang.Exception - エラーが発生した場合

• fileSystemUri

  HadoopConfigConfigurer fileSystemUri(java.lang.String uri)

  Hdfs ファイルシステム URI を指定します。
  
  JavaConfig:
  

   public void configure(HadoopConfigConfigurer config) throws Exception {
     config
       .fileSystemUri("hdfs://myhost:8020");
   }
   

  
  XML:
  

   <hadoop:configuration file-system-uri="hdfs://myhost:8020"/>
   

  パラメーター:

  uri - Hdfs uri は

  戻り値:

  連鎖用 HadoopConfigConfigurer

• resourceManagerAddress

  HadoopConfigConfigurer resourceManagerAddress(java.lang.String address)

  Yarn リソースマネージャーのアドレスを指定します。
  
  JavaConfig:
  

   public void configure(HadoopConfigConfigurer config) throws Exception {
     config
       .resourceManagerAddress("myRmHost:8032");
   }
   

  
  XML:
  

   <hadoop:configuration rm-manager-uri="myRmHost:8032"/>
   

  パラメーター:

  address - Yarn リソースマネージャーアドレス

  戻り値:

  連鎖用 HadoopConfigConfigurer

• jobHistoryAddress

  HadoopConfigConfigurer jobHistoryAddress(java.lang.String address)

  MapReduce ジョブ履歴アドレスを指定します。
  
  JavaConfig:
  

   public void configure(HadoopConfigConfigurer config) throws Exception {
     config
       .jobHistoryAddress("myJobHistoryHost:10020");
   }
   

  
  XML:
  

   <hadoop:configuration job-history-uri="myJobHistoryHost:10020"/>
   

  パラメーター:

  address - Yarn リソースマネージャーアドレス

  戻り値:

  連鎖用 HadoopConfigConfigurer

• loadDefaults

  HadoopConfigConfigurer loadDefaults(boolean loadDefaults)

  Hadoop Configuration が最初にデフォルト値に基づいているかどうかを指定します。デフォルトは true です。
  
  JavaConfig:
  

   public void configure(HadoopConfigConfigurer config) throws Exception {
     config
       .loadDefaults(true);
   }
   

  
  XML:
  同等のものはありません

  パラメーター:

  loadDefaults - デフォルトをロードするかどうかのフラグ

  戻り値:

  連鎖用 HadoopConfigConfigurer