本文整理汇总了Java中org.apache.hadoop.tools.rumen.LoggedJob类的典型用法代码示例。如果您正苦于以下问题:Java LoggedJob类的具体用法?Java LoggedJob怎么用?Java LoggedJob使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
LoggedJob类属于org.apache.hadoop.tools.rumen包,在下文中一共展示了LoggedJob类的1个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: verifySimulatedJobSummary
import org.apache.hadoop.tools.rumen.LoggedJob; //导入依赖的package包/类
/**
* It verifies the gridmix simulated job summary.
* @param zombieJob - Original job summary.
* @param jhInfo - Simulated job history info.
* @param jobConf - simulated job configuration.
* @throws IOException - if an I/O error occurs.
*/
public void verifySimulatedJobSummary(ZombieJob zombieJob,
JobHistoryParser.JobInfo jhInfo, JobConf jobConf) throws IOException {
Assert.assertEquals("Job id has not matched", zombieJob.getJobID(),
JobID.forName(jobConf.get(origJobIdKey)));
Assert.assertEquals("Job maps have not matched", zombieJob.getNumberMaps(),
jhInfo.getTotalMaps());
if (!jobConf.getBoolean(mapTaskKey, false)) {
Assert.assertEquals("Job reducers have not matched",
zombieJob.getNumberReduces(), jhInfo.getTotalReduces());
} else {
Assert.assertEquals("Job reducers have not matched",
0, jhInfo.getTotalReduces());
}
Assert.assertEquals("Job status has not matched.",
zombieJob.getOutcome().name(),
convertJobStatus(jhInfo.getJobStatus()));
LoggedJob loggedJob = zombieJob.getLoggedJob();
Assert.assertEquals("Job priority has not matched.",
loggedJob.getPriority().toString(),
jhInfo.getPriority());
if (jobConf.get(usrResolver).contains("RoundRobin")) {
String user = UserGroupInformation.getLoginUser().getShortUserName();
Assert.assertTrue(jhInfo.getJobId().toString()
+ " has not impersonate with other user.",
!jhInfo.getUsername().equals(user));
}
}
开发者ID:rekhajoshm,项目名称:mapreduce-fork,代码行数:40,代码来源:GridmixJobVerification.java
注:本文中的org.apache.hadoop.tools.rumen.LoggedJob类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论