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, getUser
public 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)
ClientRmOperations
ApplicationReport
のリストを取得します。YarnApplicationState
のセットと登録されたアプリケーション型を使用して結果をフィルター処理できます。ClientRmOperations
の listApplications
states
- 糸の用途は types
- 糸の用途型 ApplicationReport
のリスト public java.util.List<org.apache.hadoop.yarn.api.records.ApplicationReport> listApplications()
ClientRmOperations
ApplicationReport
のリストを取得します。ClientRmOperations
の listApplications
ApplicationReport
のリスト public org.apache.hadoop.yarn.api.protocolrecords.GetNewApplicationResponse getNewApplication()
ClientRmOperations
ApplicationId
を取得することですが、レスポンスにはリソース機能に関する情報も含まれます。ClientRmOperations
の getNewApplication
GetNewApplicationResponse
public org.apache.hadoop.yarn.api.protocolrecords.SubmitApplicationResponse submitApplication(org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext appSubContext)
ClientRmOperations
ClientRmOperations
の submitApplication
appSubContext
- アプリケーション提出コンテキスト SubmitApplicationResponse
public org.apache.hadoop.yarn.api.protocolrecords.KillApplicationResponse killApplication(org.apache.hadoop.yarn.api.records.ApplicationId applicationId)
ClientRmOperations
ResourceManager
にリクエストします。ClientRmOperations
の killApplication
applicationId
- アプリケーション IDKillApplicationResponse
public org.apache.hadoop.yarn.api.records.Token getDelegationToken(java.lang.String renewer)
ClientRmOperations
ClientRmOperations
の getDelegationToken
renewer
- Kerberos プリンシパルとしてのリニューア public org.apache.hadoop.yarn.api.records.ApplicationReport getApplicationReport(org.apache.hadoop.yarn.api.records.ApplicationId applicationId)
ClientRmOperations
ClientRmOperations
の getApplicationReport
applicationId
- アプリケーション IDApplicationReport
protected java.net.InetSocketAddress getRpcAddress(org.apache.hadoop.conf.Configuration config)
YarnRpcAccessor
InetSocketAddress
を取得します。YarnRpcAccessor<org.apache.hadoop.yarn.api.ApplicationClientProtocol>
の getRpcAddress
config
- 糸の構成