public class AbstractMapReduceTests extends AbstractHadoopClusterTests
applicationContext, configuration, hadoopCluster| コンストラクターと説明 |
|---|
AbstractMapReduceTests() |
| 修飾子と型 | メソッドと説明 |
|---|---|
protected JobUtils.JobStatus | findStatus(org.apache.hadoop.mapreduce.Job job) ジョブのステータスを検索します。 |
protected org.apache.hadoop.fs.Path[] | getOutputFilePaths(org.apache.hadoop.fs.Path outputDirectory)mapreduce ジョブの実行結果として生成された出力ファイル Path の配列を検索します。 |
protected org.apache.hadoop.fs.Path[] | getOutputFilePaths(java.lang.String outputDirectory)mapreduce ジョブの実行結果として生成された出力ファイル Path の配列を検索します。 |
protected JobUtils.JobStatus | waitFinishedStatus(org.apache.hadoop.mapreduce.Job job, long timeout, java.util.concurrent.TimeUnit unit) 待機完了ステータス。 |
protected JobUtils.JobStatus | waitStatus(org.apache.hadoop.mapreduce.Job job, long timeout, java.util.concurrent.TimeUnit unit, JobUtils.JobStatus... jobStatuses) 待機状態。 |
getApplicationContext, getConfiguration, getFileSystem, getHadoopCluster, setApplicationContext, setConfiguration, setHadoopClusterprotected org.apache.hadoop.fs.Path[] getOutputFilePaths(java.lang.String outputDirectory)
throws java.io.FileNotFoundException,
java.io.IOExceptionPath の配列を検索します。outputDirectory - ジョブ出力ディレクトリへのパス java.io.FileNotFoundException - 指定されたパスが見つからなかった場合 java.io.IOException - 一般的なアクセスエラーが発生した場合 getOutputFilePaths(Path)protected org.apache.hadoop.fs.Path[] getOutputFilePaths(org.apache.hadoop.fs.Path outputDirectory)
throws java.io.FileNotFoundException,
java.io.IOExceptionPath の配列を検索します。outputDirectory - ジョブ出力ディレクトリへのパス java.io.FileNotFoundException - 指定されたパスが見つからなかった場合 java.io.IOException - 一般的なアクセスエラーが発生した場合 protected JobUtils.JobStatus waitFinishedStatus(org.apache.hadoop.mapreduce.Job job, long timeout, java.util.concurrent.TimeUnit unit) throws java.lang.Exception
JobStatus.SUCCEEDED、JobStatus.FAILED、または JobStatus.KILLED のいずれかです。job - ジョブ timeout - 待機のタイムアウト unit - タイムアウトの単位 java.lang.Exception - 例外が発生した場合 protected JobUtils.JobStatus waitStatus(org.apache.hadoop.mapreduce.Job job, long timeout, java.util.concurrent.TimeUnit unit, JobUtils.JobStatus... jobStatuses) throws java.lang.Exception
NULL です。状態が一致した場合、ジョブステータスの配列を使用して待機ループからすぐに戻ることができます。job - ジョブ timeout - 待機のタイムアウト unit - タイムアウトの単位 jobStatuses - 待機するジョブステータス java.lang.Exception - 例外が発生した場合 protected JobUtils.JobStatus findStatus(org.apache.hadoop.mapreduce.Job job)
job - ジョブ