DefaultContainerAllocator (Spring for Apache Hadoop 2.5.0.RELEASE API)

java.lang.Object
- org.springframework.yarn.support.LifecycleObjectSupport
- - org.springframework.yarn.am.allocate.AbstractAllocator
  - - org.springframework.yarn.am.allocate.AbstractPollingAllocator
    - - org.springframework.yarn.am.allocate.DefaultContainerAllocator

実装されたすべてのインターフェース:
org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.InitializingBean, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle, ContainerAllocator
```
public class DefaultContainerAllocator
extends AbstractPollingAllocator
implements ContainerAllocator
```
リソースマネージャーをポーリングし、新しいコンテナーをリクエストし、同時にハートビートセンダーとして機能するデフォルトのアロケーター。
作成者:
Janne Valkealahti

コンストラクターの概要
コンストラクター
コンストラクターと説明
DefaultContainerAllocator()

コンストラクター
コンストラクターと説明
`DefaultContainerAllocator()`

メソッドのサマリー

メソッド
修飾子と型	メソッドと説明
`void`	`addListener(ContainerAllocatorListener listener)` `ContainerAllocatorListener` を追加します。
`void`	`allocateContainers(ContainerAllocateData containerAllocateData)` 新しいコンテナーを割り当てます。
`void`	`allocateContainers(int count)` 新しいコンテナーを割り当てます。
`protected org.apache.hadoop.yarn.api.protocolrecords.AllocateResponse`	`doContainerRequest()` サブクラスは、リソースマネージャーに対してコンテナーリクエストを実行するためにこのメソッドを実装する必要があります。
`int`	`getMemory()` コンテナーリクエストのメモリを取得します。
`int`	`getPriority()` コンテナーリクエストの優先度を取得します。
`int`	`getVirtualcores()` コンテナーリクエストの仮想コアを取得します。
`protected void`	`handleAllocatedContainers(java.util.List<org.apache.hadoop.yarn.api.records.Container> containers)` サブクラスは、新しく割り当てられたコンテナーを処理するためにこのメソッドを実装する必要があります。
`protected void`	`handleCompletedContainers(java.util.List<org.apache.hadoop.yarn.api.records.ContainerStatus> containerStatuses)` サブクラスは、新しくリリースされたコンテナーを処理するためにこのメソッドを実装する必要があります。
`boolean`	`isLocality()` ローカリティリラックスフラグが有効になっているかどうかを確認します。
`protected void`	`onInit()` サブクラスは、初期化ロジック用にこれを実装できます。
`protected java.util.List<org.apache.hadoop.yarn.api.records.Container>`	`preProcessAllocatedContainers(java.util.List<org.apache.hadoop.yarn.api.records.Container> containers)` 割り当てられたコンテナーを前処理します。
`void`	`releaseContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId)` コンテナーを解放します。
`void`	`releaseContainers(java.util.List<org.apache.hadoop.yarn.api.records.Container> containers)` コンテナーを解放します。
`void`	`setAllocationValues(java.lang.String id, java.lang.Integer priority, java.lang.String labelExpression, java.lang.Integer virtualcores, java.lang.Integer memory, java.lang.Boolean locality)` 指定された識別子の割り当て値を設定します。
`void`	`setLabelExpression(java.lang.String labelExpression)` ラベル式を設定します。
`void`	`setLocality(boolean locality)` リソース割り当てを緩和すべきでないかどうかを示すフラグを設定します。
`void`	`setMemory(int memory)` リソースのメモリを定義するコンテナーリクエストのメモリを設定します。
`void`	`setPriority(int priority)` コンテナーリクエストの優先度を設定します。
`void`	`setProgress(float progress)` アプリケーションの現在の進行状況を設定します。
`void`	`setVirtualcores(int virtualcores)` リソースの仮想 CPU コアの数を定義するコンテナーリクエストの仮想コアを設定します。

クラス org.springframework.yarn.am.allocate.AbstractPollingAllocator から継承されたメソッド
doStart, doStop, populateNmTokenCache, setTrigger

クラス org.springframework.yarn.am.allocate.AbstractAllocator から継承されたメソッド
getApplicationAttemptId, getConfiguration, getEnvironment, getRmTemplate, setApplicationAttemptId, setConfiguration, setEnvironment, setRmTemplate

クラス org.springframework.yarn.support.LifecycleObjectSupport から継承されたメソッド
afterPropertiesSet, getBeanFactory, getPhase, getTaskExecutor, getTaskScheduler, getYarnEventPublisher, isAutoStartup, isRunning, setAutoStartup, setBeanFactory, setPhase, setTaskExecutor, setTaskScheduler, setYarnEventPublisher, start, stop, stop

クラス java.lang.Object から継承されたメソッド
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- コンストラクターの詳細
  - DefaultContainerAllocator
```
public DefaultContainerAllocator()
```
- メソッドの詳細
  - onInit
```
protected void onInit()
               throws java.lang.Exception
```
    クラスからコピーされた説明: LifecycleObjectSupport
    サブクラスは、初期化ロジックのためにこれを実装できます。InitializingBean フェーズ中に呼び出されます。作成者は、初期化チェーンを壊さないように、常にスーパーメソッドを呼び出す必要があります。
    オーバーライド:
    クラス AbstractPollingAllocator の onInit
    例外:
    java.lang.Exception - 例外
  - allocateContainers
```
public void allocateContainers(int count)
```
    インターフェースからコピーされた説明: ContainerAllocator
    新しいコンテナーを割り当てます。
    次で指定:
    インターフェース ContainerAllocator の allocateContainers
    パラメーター:
    count - 割り当てる新しいコンテナー数
  - addListener
```
public void addListener(ContainerAllocatorListener listener)
```
    インターフェースからコピーされた説明: ContainerAllocator
    ContainerAllocatorListener を追加します。
    次で指定:
    インターフェース ContainerAllocator の addListener
    パラメーター:
    listener - ContainerAllocatorListener
  - allocateContainers
```
public void allocateContainers(ContainerAllocateData containerAllocateData)
```
    インターフェースからコピーされた説明: ContainerAllocator
    新しいコンテナーを割り当てます。
    次で指定:
    インターフェース ContainerAllocator の allocateContainers
    パラメーター:
    containerAllocateData - ContainerAllocateData
  - releaseContainers
```
public void releaseContainers(java.util.List<org.apache.hadoop.yarn.api.records.Container> containers)
```
    インターフェースからコピーされた説明: ContainerAllocator
    コンテナーを解放します。
    次で指定:
    インターフェース ContainerAllocator の releaseContainers
    パラメーター:
    containers - コンテナー
  - releaseContainer
```
public void releaseContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId)
```
    インターフェースからコピーされた説明: ContainerAllocator
    コンテナーを解放します。
    次で指定:
    インターフェース ContainerAllocator の releaseContainer
    パラメーター:
    containerId - コンテナー ID
  - doContainerRequest
```
protected org.apache.hadoop.yarn.api.protocolrecords.AllocateResponse doContainerRequest()
```
    クラスからコピーされた説明: AbstractPollingAllocator
    サブクラスは、リソースマネージャーに対してコンテナーリクエストを行うためにこのメソッドを実装する必要があります。このメソッドは、このクラスによって処理されるポーリングサイクル中に呼び出されます。新しいコンテナーと新しく解放されたコンテナーは、メソッド AbstractPollingAllocator.handleAllocatedContainers(List) と AbstractPollingAllocator.handleCompletedContainers(List) に渡されます。
    次で指定:
    クラス AbstractPollingAllocator の doContainerRequest
    戻り値:
    リソースマネージャーからの AllocateResponse
  - preProcessAllocatedContainers
```
protected java.util.List<org.apache.hadoop.yarn.api.records.Container> preProcessAllocatedContainers(java.util.List<org.apache.hadoop.yarn.api.records.Container> containers)
```
    クラスからコピーされた説明: AbstractPollingAllocator
    割り当てられたコンテナーを前処理します。実装者は、さらに処理が行われる前にコンテナーをインターセプトできます。デフォルトの実装では、リストがそのまま返されます。
    オーバーライド:
    クラス AbstractPollingAllocator の preProcessAllocatedContainers
    パラメーター:
    containers - コンテナー
    戻り値:
    コンテナーのリスト
  - handleAllocatedContainers
```
protected void handleAllocatedContainers(java.util.List<org.apache.hadoop.yarn.api.records.Container> containers)
```
    クラスからコピーされた説明: AbstractPollingAllocator
    サブクラスは、新しく割り当てられたコンテナーを処理するためにこのメソッドを実装する必要があります。
    次で指定:
    クラス AbstractPollingAllocator の handleAllocatedContainers
    パラメーター:
    containers - 新しく割り当てられたコンテナーのリスト
  - handleCompletedContainers
```
protected void handleCompletedContainers(java.util.List<org.apache.hadoop.yarn.api.records.ContainerStatus> containerStatuses)
```
    クラスからコピーされた説明: AbstractPollingAllocator
    サブクラスは、新しくリリースされたコンテナーを処理するためにこのメソッドを実装する必要があります。
    次で指定:
    クラス AbstractPollingAllocator の handleCompletedContainers
    パラメーター:
    containerStatuses - 新しくリリースされたコンテナーのリスト
  - setProgress
```
public void setProgress(float progress)
```
    インターフェースからコピーされた説明: ContainerAllocator
    アプリケーションの現在の進行状況を設定します。
    次で指定:
    インターフェース ContainerAllocator の setProgress
    パラメーター:
    progress - 現在の申請の進捗状況
  - setAllocationValues
```
public void setAllocationValues(java.lang.String id,
                       java.lang.Integer priority,
                       java.lang.String labelExpression,
                       java.lang.Integer virtualcores,
                       java.lang.Integer memory,
                       java.lang.Boolean locality)
```
    指定された識別子の割り当て値を設定します。
    パラメーター:
    id - 割り当て識別子
    priority - 基本優先順位
    labelExpression - ラベル表現
    virtualcores - CPU 数
    memory - 想い出
    locality - 地域旗
  - getPriority
```
public int getPriority()
```
    コンテナーリクエストの優先度を取得します。
    戻り値:
    優先順位
  - setPriority
```
public void setPriority(int priority)
```
    コンテナーリクエストの優先度を設定します。
    パラメーター:
    priority - 新たな優先事項
  - setLabelExpression
```
public void setLabelExpression(java.lang.String labelExpression)
```
    ラベル式を設定します。
    パラメーター:
    labelExpression - 新しいラベル表現
  - getVirtualcores
```
public int getVirtualcores()
```
    コンテナーリクエストの仮想コアを取得します。
    戻り値:
    仮想コア
  - setVirtualcores
```
public void setVirtualcores(int virtualcores)
```
    リソースの仮想 CPU コアの数を定義するコンテナーリクエストの仮想コアを設定します。
    パラメーター:
    virtualcores - 新しい仮想コア
  - getMemory
```
public int getMemory()
```
    コンテナーリクエストのメモリを取得します。
    戻り値:
    想い出
  - setMemory
```
public void setMemory(int memory)
```
    リソースのメモリを定義するコンテナーリクエストのメモリを設定します。
    パラメーター:
    memory - 新しい記憶
  - isLocality
```
public boolean isLocality()
```
    ローカリティリラックスフラグが有効になっているかどうかを確認します。
    戻り値:
    ローカリティが有効な場合は true。
  - setLocality
```
public void setLocality(boolean locality)
```
    リソース割り当てを緩和すべきでないかどうかを示すフラグを設定します。これを true に設定すると、緩和は使用されません。デフォルト値は false です。
    パラメーター:
    locality - 新しい地域リラックスフラグ

クラス DefaultContainerAllocator

コンストラクターの概要

メソッドのサマリー

クラス org.springframework.yarn.am.allocate.AbstractPollingAllocator から継承されたメソッド

クラス org.springframework.yarn.am.allocate.AbstractAllocator から継承されたメソッド

クラス org.springframework.yarn.support.LifecycleObjectSupport から継承されたメソッド

クラス java.lang.Object から継承されたメソッド

コンストラクターの詳細

DefaultContainerAllocator

メソッドの詳細

onInit

allocateContainers

addListener

allocateContainers

releaseContainers

releaseContainer

doContainerRequest

preProcessAllocatedContainers

handleAllocatedContainers

handleCompletedContainers

setProgress

setAllocationValues

getPriority

setPriority

setLabelExpression

getVirtualcores

setVirtualcores

getMemory

setMemory

isLocality

setLocality