フィールドの詳細

• log

  protected org.apache.commons.logging.Log log

コンストラクターの詳細

• JobExecutor

  public JobExecutor()

メソッドの詳細

• afterPropertiesSet

  public void afterPropertiesSet()
                          throws java.lang.Exception

  次で指定:

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

  例外:

  java.lang.Exception

• destroy

  public void destroy()
               throws java.lang.Exception

  次で指定:

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

  例外:

  java.lang.Exception

• stopJobs

  protected java.util.Collection<org.apache.hadoop.mapreduce.Job> stopJobs()

  実行中のジョブを停止します。

  戻り値:

  停止されたジョブのリスト。

• stopJobs

  protected java.util.Collection<org.apache.hadoop.mapreduce.Job> stopJobs(JobExecutor.JobListener listener)

  実行中のジョブを停止します。

  パラメーター:

  listener - ジョブリスナー

  戻り値:

  停止されたジョブのリスト。

• startJobs

  protected java.util.Collection<org.apache.hadoop.mapreduce.Job> startJobs()

• startJobs

  protected java.util.Collection<org.apache.hadoop.mapreduce.Job> startJobs(JobExecutor.JobListener listener)

• findJobs

  protected java.util.Collection<org.apache.hadoop.mapreduce.Job> findJobs()

• setJob

  public void setJob(org.apache.hadoop.mapreduce.Job job)

  実行するジョブを設定します。

  パラメーター:

  job - 実行するジョブ。

• setJobs

  public void setJobs(java.util.Collection<org.apache.hadoop.mapreduce.Job> jobs)

  実行するジョブを設定します。

  パラメーター:

  jobs - 実行するジョブ。

• setJobNames

  public void setJobNames(java.lang.String... jobName)

  (Bean) 名で実行するジョブを設定します。これは、遅延初期化と潜在的なスコープを有効にするために hdp 名前空間で使用されるデフォルトの方法です。

  パラメーター:

  jobName - 実行するジョブ。

• isWaitForCompletion

  public boolean isWaitForCompletion()

  「ランナー」がジョブの完了を待機するかどうかを示します (デフォルト)。

  戻り値:

  ジョブが完了するまで待機するかどうか。

• setWaitForCompletion

  public void setWaitForCompletion(boolean waitForJob)

  送信後に「ランナー」がジョブの完了 (デフォルト) を待機するかどうかを示します。

  パラメーター:

  waitForJob - ジョブが完了するまで待機するかどうか。

• isVerbose

  public boolean isVerbose()

  ジョブ実行が詳細 (デフォルト) かどうかを示します。

  戻り値:

  ジョブ実行が詳細かどうか。

• setVerbose

  public void setVerbose(boolean verbose)

  ジョブ実行が詳細 (デフォルト) かどうかを示します。

  パラメーター:

  verbose - ジョブ実行が詳細かどうか。

• setBeanFactory

  public void setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory)
                      throws org.springframework.beans.BeansException

  次で指定:

  インターフェース org.springframework.beans.factory.BeanFactoryAware 内の setBeanFactory 

  例外:

  org.springframework.beans.BeansException

• setExecutor

  public void setExecutor(java.util.concurrent.Executor executor)

  Hadoop ジョブの実行に使用される TaskExecutor を設定します。デフォルトでは、呼び出しスレッドが使用されることを意味する SyncTaskExecutor が使用されます。これは Hadoop の動作を再現しますが、アプリケーションがシャットダウンした場合に実行中のジョブが強制終了されるのを防ぎます。微調整された制御には、専用の Executor をお勧めします。

  パラメーター:

  executor - Hadoop ジョブを実行するために使用するタスクエグゼキュータ。

• isKillJobsAtShutdown

  public boolean isKillJobsAtShutdown()

  アプリケーションのシャットダウン時に、構成されたジョブを「強制終了」するかどうかを示します。

  戻り値:

  シャットダウン時に設定されたジョブを強制終了するかどうか

• setKillJobAtShutdown

  public void setKillJobAtShutdown(boolean killJobsAtShutdown)

  アプリケーションがシャットダウンするときに、構成されたジョブを「強制終了」するかどうかを示します (デフォルト)。起動アプリケーションを超えて存続する長時間実行ジョブまたはファイアアンドフォーゲットジョブの場合は、これを false に設定します。setWaitForCompletion(boolean) が true の場合、このフラグは true とみなされます。そうでない場合、アプリケーションはシャットダウンできません (ジョブを待機し続ける必要があるため)。

  パラメーター:

  killJobsAtShutdown - アプリケーションのシャットダウン時に設定されたジョブを強制終了するかどうか