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, stop
public final void run()
YarnContainer
YarnContainer
の run
public void setEnvironment(java.util.Map<java.lang.String,java.lang.String> environment)
YarnContainer
YarnContainer
の setEnvironment
environment
- 環境変数 public void setParameters(java.util.Properties parameters)
YarnContainer
YarnContainer
の setParameters
parameters
- パラメーター public void addContainerStateListener(ContainerStateListener listener)
LongRunningYarnContainer
LongRunningYarnContainer
の addContainerStateListener
listener
- ContainerStateListener
public boolean isWaitCompleteState()
LongRunningYarnContainer
COMPLETED
状態を待機する必要があるかどうかを示します。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()
メソッドを処理するための内部メソッド。