setJobConf() |  | 0% |  | 0% | 57 | 57 | 155 | 155 | 1 | 1 |
parseArgv() |  | 0% |  | 0% | 35 | 35 | 87 | 87 | 1 | 1 |
printUsage(boolean) |  | 0% |  | 0% | 2 | 2 | 93 | 93 | 1 | 1 |
setupOptions() |  | 0% | | n/a | 1 | 1 | 56 | 56 | 1 | 1 |
submitAndMonitorJob() |  | 0% |  | 0% | 5 | 5 | 31 | 31 | 1 | 1 |
packageJobJar() |  | 0% |  | 0% | 9 | 9 | 25 | 25 | 1 | 1 |
unqualifyIfLocalPath(String) |  | 0% |  | 0% | 5 | 5 | 20 | 20 | 1 | 1 |
postProcessArgs() |  | 0% |  | 0% | 5 | 5 | 15 | 15 | 1 | 1 |
listJobConfProperties() |  | 0% |  | 0% | 3 | 3 | 10 | 10 | 1 | 1 |
StreamJob() |  | 0% | | n/a | 1 | 1 | 10 | 10 | 1 | 1 |
run(String[]) |  | 0% |  | 0% | 2 | 2 | 14 | 14 | 1 | 1 |
validate(Path) |  | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
createJob(String[]) |  | 0% | | n/a | 1 | 1 | 8 | 8 | 1 | 1 |
StreamJob(String[], boolean) |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
getURIs(String, String) |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
msg(String) |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
init() |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
createOption(String, String, String, int, boolean) |  | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
go() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
fail(String) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
getHadoopClientHome() |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
preProcessArgs() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
exitUsage(boolean) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
createBoolOption(String, String) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getJobTrackerHostPort() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
static {...} | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
setConf(Configuration) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
isLocalHadoop() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getConf() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getClusterNick() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |