kazusa
/
skywalking-java
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

1.修改reduce的方法。

This commit is contained in:
wusheng 2016-01-22 21:39:19 +08:00
parent 3af2163173
commit 7614ca8f86
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
skywalking-analysis/src/main/java/com/ai/cloud/skywalking/analysis/AnalysisServerDriver.java
View File

@ -45,8 +45,8 @@ public class AnalysisServerDriver extends Configured implements Tool {
TableMapReduceUtil.initTableMapperJob(Config.HBase.CALL_CHAIN_TABLE_NAME, scan, Categorize2ChainMapper.class,
String.class, ChainInfo.class, job);
TableMapReduceUtil.initTableReducerJob(Config.HBase.CALL_CHAIN_TABLE_NAME, Categorize2ChainReduce.class, job);
job.setReducerClass(Categorize2ChainReduce.class);
return job.waitForCompletion(true) ? 0 : 1;
}