public class ClientRmTemplate extends YarnRpcAccessor<org.apache.hadoop.yarn.api.ApplicationClientProtocol> implements ClientRmOperations
ApplicationClientProtocol を使用して通信をラップする ClientRmOperations のテンプレートの実装。このテンプレートのメソッドは、起こりうる例外を Spring Dao 例外階層にラップします。| コンストラクターと説明 |
|---|
ClientRmTemplate(org.apache.hadoop.conf.Configuration config) 指定された糸構成で ClientRmTemplate を構築します。 |
| 修飾子と型 | メソッドと説明 |
|---|---|
org.apache.hadoop.yarn.api.records.ApplicationReport | getApplicationReport(org.apache.hadoop.yarn.api.records.ApplicationId applicationId) アプリケーションのレポートを取得します。 |
org.apache.hadoop.yarn.api.records.Token | getDelegationToken(java.lang.String renewer) リソースマネージャー委譲トークンを取得します。 |
org.apache.hadoop.yarn.api.protocolrecords.GetNewApplicationResponse | getNewApplication() リソースマネージャーに新しいアプリケーションをリクエストします。 |
protected java.net.InetSocketAddress | getRpcAddress(org.apache.hadoop.conf.Configuration config) このアクセサーが接続する InetSocketAddress を取得します。 |
org.apache.hadoop.yarn.api.protocolrecords.KillApplicationResponse | killApplication(org.apache.hadoop.yarn.api.records.ApplicationId applicationId) 送信されたアプリケーションを中止するように ResourceManager にリクエストします。 |
java.util.List<org.apache.hadoop.yarn.api.records.ApplicationReport> | listApplications() リソースマネージャーから ApplicationReport のリストを取得します。 |
java.util.List<org.apache.hadoop.yarn.api.records.ApplicationReport> | listApplications(java.util.EnumSet<org.apache.hadoop.yarn.api.records.YarnApplicationState> states, java.util.Set<java.lang.String> types) リソースマネージャーから ApplicationReport のリストを取得します。 |
org.apache.hadoop.yarn.api.protocolrecords.SubmitApplicationResponse | submitApplication(org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext appSubContext) 新しいアプリケーションをリソースマネージャーに送信します。 |
afterPropertiesSet, createProxy, destroy, execute, getConfiguration, getProxy, getUserpublic ClientRmTemplate(org.apache.hadoop.conf.Configuration config)
ClientRmTemplate を構築します。config - 糸の構成 public java.util.List<org.apache.hadoop.yarn.api.records.ApplicationReport> listApplications(java.util.EnumSet<org.apache.hadoop.yarn.api.records.YarnApplicationState> states,
java.util.Set<java.lang.String> types)ClientRmOperationsApplicationReport のリストを取得します。YarnApplicationState のセットと登録されたアプリケーション型を使用して結果をフィルター処理できます。ClientRmOperations の listApplications states - 糸の用途は types - 糸の用途型 ApplicationReport のリスト public java.util.List<org.apache.hadoop.yarn.api.records.ApplicationReport> listApplications()
ClientRmOperationsApplicationReport のリストを取得します。ClientRmOperations の listApplications ApplicationReport のリスト public org.apache.hadoop.yarn.api.protocolrecords.GetNewApplicationResponse getNewApplication()
ClientRmOperationsApplicationId を取得することですが、レスポンスにはリソース機能に関する情報も含まれます。ClientRmOperations の getNewApplication GetNewApplicationResponsepublic org.apache.hadoop.yarn.api.protocolrecords.SubmitApplicationResponse submitApplication(org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext appSubContext)
ClientRmOperationsClientRmOperations の submitApplication appSubContext - アプリケーション提出コンテキスト SubmitApplicationResponsepublic org.apache.hadoop.yarn.api.protocolrecords.KillApplicationResponse killApplication(org.apache.hadoop.yarn.api.records.ApplicationId applicationId)
ClientRmOperationsResourceManager にリクエストします。ClientRmOperations の killApplication applicationId - アプリケーション IDKillApplicationResponsepublic org.apache.hadoop.yarn.api.records.Token getDelegationToken(java.lang.String renewer)
ClientRmOperationsClientRmOperations の getDelegationToken renewer - Kerberos プリンシパルとしてのリニューア public org.apache.hadoop.yarn.api.records.ApplicationReport getApplicationReport(org.apache.hadoop.yarn.api.records.ApplicationId applicationId)
ClientRmOperationsClientRmOperations の getApplicationReport applicationId - アプリケーション IDApplicationReportprotected java.net.InetSocketAddress getRpcAddress(org.apache.hadoop.conf.Configuration config)
YarnRpcAccessorInetSocketAddress を取得します。YarnRpcAccessor<org.apache.hadoop.yarn.api.ApplicationClientProtocol> の getRpcAddress config - 糸の構成