コンストラクターの詳細

• YarnRpcAccessor

  public YarnRpcAccessor(java.lang.Class<P> protocolClazz,
                 org.apache.hadoop.conf.Configuration config)

  プロトコルクラスと Yarn 構成を使用して新しい yarn rpc アクセサーをインスタンス化します。

  パラメーター:

  protocolClazz - プロトコルクラッズ

  config - 糸の構成

メソッドの詳細

• afterPropertiesSet

  public void afterPropertiesSet()
                          throws java.lang.Exception

  次で指定:

  インターフェース org.springframework.beans.factory.InitializingBean の afterPropertiesSet 

  例外:

  java.lang.Exception

• destroy

  public void destroy()

  次で指定:

  インターフェース org.springframework.beans.factory.DisposableBean の destroy 

• getProxy

  public P getProxy()

  このアクセサーによって処理されるプロキシを取得します。

  戻り値:

  プロキシ

• execute

  public <T,S extends P> T execute(YarnRpcCallback<T,S> action)
            throws org.springframework.dao.DataAccessException

  RPC プロキシで指定されたアクションコールバックを実行します。

  型パラメーター:

  T - 戻り型

  S - プロキシ型

  パラメーター:

  action - アクション

  戻り値:

  コールバック実行の結果

  例外:

  org.springframework.dao.DataAccessException - データアクセス例外

• getConfiguration

  public org.apache.hadoop.conf.Configuration getConfiguration()

  Yarn 構成を取得します。

  戻り値:

  Yarn 構成

• createProxy

  protected P createProxy()
                   throws java.io.IOException

  プロキシを作成します。getUser() が null 以外の user を返す場合、PrivilegedAction でプロキシをリクエストするために使用されます。

  戻り値:

  プロキシ

  例外:

  java.io.IOException - 作成に失敗した場合

• getUser

  protected org.apache.hadoop.security.UserGroupInformation getUser()
                                                             throws java.io.IOException

  プロキシの作成に使用される user を取得します。デフォルトの実装は UserGroupInformation.getCurrentUser() に委譲されます。

  戻り値:

  ユーザー

  例外:

  java.io.IOException - ログインに失敗した場合

  関連事項:

  createProxy()

• getRpcAddress

  protected abstract java.net.InetSocketAddress getRpcAddress(org.apache.hadoop.conf.Configuration configuration)

  このアクセサーが接続する InetSocketAddress を取得します。

  パラメーター:

  configuration - 糸の構成

  戻り値:

  RPC エンドポイントのアドレス