public abstract class AbstractPollingAllocator extends AbstractAllocator
| コンストラクターと説明 |
|---|
AbstractPollingAllocator() |
| 修飾子と型 | メソッドと説明 |
|---|---|
protected abstract org.apache.hadoop.yarn.api.protocolrecords.AllocateResponse | doContainerRequest() サブクラスは、リソースマネージャーに対してコンテナーリクエストを実行するためにこのメソッドを実装する必要があります。 |
protected void | doStart() サブクラスは、開始動作でこのメソッドを実装できます。 |
protected void | doStop() サブクラスは、停止動作でこのメソッドを実装できます。 |
protected abstract void | handleAllocatedContainers(java.util.List<org.apache.hadoop.yarn.api.records.Container> containers) サブクラスは、新しく割り当てられたコンテナーを処理するためにこのメソッドを実装する必要があります。 |
protected abstract void | handleCompletedContainers(java.util.List<org.apache.hadoop.yarn.api.records.ContainerStatus> containerStatuses) サブクラスは、新しくリリースされたコンテナーを処理するためにこのメソッドを実装する必要があります。 |
protected void | onInit() サブクラスは、初期化ロジック用にこれを実装できます。 |
protected void | populateNmTokenCache(org.apache.hadoop.yarn.api.protocolrecords.AllocateResponse allocateResponse)NMTokenCache にノードマネージャートークンキャッシュを入力します。 |
protected java.util.List<org.apache.hadoop.yarn.api.records.Container> | preProcessAllocatedContainers(java.util.List<org.apache.hadoop.yarn.api.records.Container> containers) 割り当てられたコンテナーを前処理します。 |
void | setTrigger(org.springframework.scheduling.Trigger trigger) ポーリングタスクをトリガーするために使用される Trigger を設定します。 |
getApplicationAttemptId, getConfiguration, getEnvironment, getRmTemplate, setApplicationAttemptId, setConfiguration, setEnvironment, setRmTemplateafterPropertiesSet, getBeanFactory, getPhase, getTaskExecutor, getTaskScheduler, getYarnEventPublisher, isAutoStartup, isRunning, setAutoStartup, setBeanFactory, setPhase, setTaskExecutor, setTaskScheduler, setYarnEventPublisher, start, stop, stoppublic void setTrigger(org.springframework.scheduling.Trigger trigger)
Trigger を設定します。trigger - トリガーを設定する protected void onInit()
throws java.lang.ExceptionLifecycleObjectSupportInitializingBean フェーズ中に呼び出されます。作成者は、初期化 チェーンを壊さないように、常にスーパーメソッドを呼び出す必要があります。AbstractAllocator の onInit java.lang.Exception - 例外 protected void doStart()
LifecycleObjectSupportLifecycleObjectSupport.lifecycleLock を保持している間に呼び出されます。LifecycleObjectSupport の doStart protected void doStop()
LifecycleObjectSupportLifecycleObjectSupport.lifecycleLock を保持している間に呼び出されます。LifecycleObjectSupport の doStop protected abstract org.apache.hadoop.yarn.api.protocolrecords.AllocateResponse doContainerRequest()
handleAllocatedContainers(List) と handleCompletedContainers(List) に渡されます。AllocateResponse protected java.util.List<org.apache.hadoop.yarn.api.records.Container> preProcessAllocatedContainers(java.util.List<org.apache.hadoop.yarn.api.records.Container> containers)
containers - コンテナー protected abstract void handleAllocatedContainers(java.util.List<org.apache.hadoop.yarn.api.records.Container> containers)
containers - 新しく割り当てられたコンテナーのリスト protected abstract void handleCompletedContainers(java.util.List<org.apache.hadoop.yarn.api.records.ContainerStatus> containerStatuses)
containerStatuses - 新しくリリースされたコンテナーのリスト protected void populateNmTokenCache(org.apache.hadoop.yarn.api.protocolrecords.AllocateResponse allocateResponse)
NMTokenCache にノードマネージャートークンキャッシュを入力します。allocateResponse - 割り当てレスポンス