public abstract class AbstractYarnContainer extends LifecycleObjectSupport implements LongRunningYarnContainer, YarnContainerRuntime
run() の処理などの一般的な機能を提供する YarnContainer の基本実装です。| コンストラクターと説明 |
|---|
AbstractYarnContainer() |
| 修飾子と型 | メソッドと説明 |
|---|---|
void | addContainerStateListener(ContainerStateListener listener) コンテナー状態リスナーを追加します。 |
org.apache.hadoop.conf.Configuration | getConfiguration()Yarn 構成を取得します。 |
java.util.Map<java.lang.String,java.lang.String> | getEnvironment() 環境を取得します。 |
java.lang.String | getEnvironment(java.lang.String key) 環境変数を取得します。 |
java.util.Properties | getParameters() パラメーターを取得します。 |
boolean | isWaitCompleteState() この Bean を使用する可能性のあるハンドラーが COMPLETED 状態を待機する必要があるかどうかを示します。 |
protected void | notifyCompleted() コンテナー状態リスナーに完了状態を通知します。 |
protected void | notifyCompleted(int exit) コンテナー状態リスナーに完了状態を通知します。 |
protected void | notifyContainerState(ContainerStateListener.ContainerState state, java.lang.Object exit) コンテナー状態リスナーに状態を通知します。 |
void | run() このメソッドは、コンテナー内で何かが実行されたときに呼び出されます。 |
protected abstract void | runInternal() 実際の run() メソッドを処理するための内部メソッド。 |
void | setConfiguration(org.apache.hadoop.conf.Configuration configuration)Yarn 構成を設定します。 |
void | setEnvironment(java.util.Map<java.lang.String,java.lang.String> environment) 環境変数を設定します。 |
void | setParameters(java.util.Properties parameters) パラメーターを設定します。 |
afterPropertiesSet, doStart, doStop, getBeanFactory, getPhase, getTaskExecutor, getTaskScheduler, getYarnEventPublisher, isAutoStartup, isRunning, onInit, setAutoStartup, setBeanFactory, setPhase, setTaskExecutor, setTaskScheduler, setYarnEventPublisher, start, stop, stoppublic final void run()
YarnContainerYarnContainer 内の run public void setEnvironment(java.util.Map<java.lang.String,java.lang.String> environment)
YarnContainerYarnContainer 内の setEnvironment environment - 環境変数 public void setParameters(java.util.Properties parameters)
YarnContainerYarnContainer 内の setParameters parameters - パラメーター public void addContainerStateListener(ContainerStateListener listener)
LongRunningYarnContainerLongRunningYarnContainer 内の addContainerStateListener listener - ContainerStateListenerpublic boolean isWaitCompleteState()
LongRunningYarnContainerCOMPLETED 状態を待機する必要があるかどうかを示します。LongRunningYarnContainer 内の isWaitCompleteState LongRunningYarnContainer.addContainerStateListener(ContainerStateListener)public org.apache.hadoop.conf.Configuration getConfiguration()
public void setConfiguration(org.apache.hadoop.conf.Configuration configuration)
configuration - 新しい Yarn 構成 public java.lang.String getEnvironment(java.lang.String key)
key - キー null public java.util.Map<java.lang.String,java.lang.String> getEnvironment()
YarnContainerRuntime 内の getEnvironment public java.util.Properties getParameters()
YarnContainerRuntime 内の getParameters protected void notifyCompleted()
protected void notifyCompleted(int exit)
exit - 出口 protected void notifyContainerState(ContainerStateListener.ContainerState state, java.lang.Object exit)
state - 状態 exit - 出口 protected abstract void runInternal()
run() メソッドを処理するための内部メソッド。