|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||
java.lang.Objectorg.springframework.data.hadoop.test.junit.AbstractHadoopClusterTests
org.springframework.data.hadoop.test.junit.AbstractMapReduceTests
public class AbstractMapReduceTests
Abstract base class providing default functionality for running map reduce tests.
| Field Summary |
|---|
| Fields inherited from class org.springframework.data.hadoop.test.junit.AbstractHadoopClusterTests |
|---|
applicationContext, configuration, hadoopCluster |
| Constructor Summary | |
|---|---|
AbstractMapReduceTests()
|
|
| Method Summary | |
|---|---|
protected org.springframework.data.hadoop.mapreduce.JobUtils.JobStatus |
findStatus(Job job)
Find job status. |
protected Path[] |
getOutputFilePaths(Path outputDirectory)
Finds an array of output file Paths resulted as
mapreduce job run. |
protected Path[] |
getOutputFilePaths(String outputDirectory)
Finds an array of output file Paths resulted as
mapreduce job run. |
protected org.springframework.data.hadoop.mapreduce.JobUtils.JobStatus |
waitFinishedStatus(Job job,
long timeout,
TimeUnit unit)
Wait finished status. |
protected org.springframework.data.hadoop.mapreduce.JobUtils.JobStatus |
waitStatus(Job job,
long timeout,
TimeUnit unit,
org.springframework.data.hadoop.mapreduce.JobUtils.JobStatus... jobStatuses)
Waits state. |
| Methods inherited from class org.springframework.data.hadoop.test.junit.AbstractHadoopClusterTests |
|---|
getApplicationContext, getConfiguration, getFileSystem, getHadoopCluster, setApplicationContext, setConfiguration, setHadoopCluster |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Constructor Detail |
|---|
public AbstractMapReduceTests()
| Method Detail |
|---|
protected Path[] getOutputFilePaths(String outputDirectory)
throws FileNotFoundException,
IOException
Paths resulted as
mapreduce job run.
outputDirectory - the path to jobs output directory
FileNotFoundException - if given path was not found
IOException - if general access error occuredgetOutputFilePaths(Path)
protected Path[] getOutputFilePaths(Path outputDirectory)
throws FileNotFoundException,
IOException
Paths resulted as
mapreduce job run.
outputDirectory - the path to jobs output directory
FileNotFoundException - if given path was not found
IOException - if general access error occured
protected org.springframework.data.hadoop.mapreduce.JobUtils.JobStatus waitFinishedStatus(Job job,
long timeout,
TimeUnit unit)
throws Exception
JobStatus.SUCCEEDED, JobStatus.FAILED or JobStatus.KILLED.
job - the jobtimeout - the timeout for waitunit - the unit for timeout
Exception - if exception occurred
protected org.springframework.data.hadoop.mapreduce.JobUtils.JobStatus waitStatus(Job job,
long timeout,
TimeUnit unit,
org.springframework.data.hadoop.mapreduce.JobUtils.JobStatus... jobStatuses)
throws Exception
NULL
if something failed or final known state after the wait/poll operations.
Array of job statuses can be used to return immediately from wait
loop if state is matched.
job - the jobtimeout - the timeout for waitunit - the unit for timeoutjobStatuses - the job statuses to wait
Exception - if exception occurredprotected org.springframework.data.hadoop.mapreduce.JobUtils.JobStatus findStatus(Job job)
job - the job
|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||