提交 f20c8605 编写于 作者: Y You Yong

Merge branch 'master' of ssh://192.168.8.22:58422/cat

...@@ -120,6 +120,16 @@ ...@@ -120,6 +120,16 @@
<data-source-name>cat</data-source-name> <data-source-name>cat</data-source-name>
</configuration> </configuration>
</component> </component>
<component>
<role>com.site.dal.jdbc.mapping.TableProvider</role>
<role-hint>location</role-hint>
<implementation>com.site.dal.jdbc.mapping.SimpleTableProvider</implementation>
<configuration>
<logical-table-name>location</logical-table-name>
<physical-table-name>location</physical-table-name>
<data-source-name>cat</data-source-name>
</configuration>
</component>
<component> <component>
<role>com.site.dal.jdbc.mapping.TableProvider</role> <role>com.site.dal.jdbc.mapping.TableProvider</role>
<role-hint>logview</role-hint> <role-hint>logview</role-hint>
...@@ -196,6 +206,15 @@ ...@@ -196,6 +206,15 @@
</requirement> </requirement>
</requirements> </requirements>
</component> </component>
<component>
<role>com.dianping.cat.hadoop.dal.LocationDao</role>
<implementation>com.dianping.cat.hadoop.dal.LocationDao</implementation>
<requirements>
<requirement>
<role>com.site.dal.jdbc.QueryEngine</role>
</requirement>
</requirements>
</component>
<component> <component>
<role>com.dianping.cat.hadoop.dal.LogviewDao</role> <role>com.dianping.cat.hadoop.dal.LogviewDao</role>
<implementation>com.dianping.cat.hadoop.dal.LogviewDao</implementation> <implementation>com.dianping.cat.hadoop.dal.LogviewDao</implementation>
......
...@@ -172,8 +172,9 @@ public class DefaultTaskConsumer extends TaskConsumer implements LogEnabled { ...@@ -172,8 +172,9 @@ public class DefaultTaskConsumer extends TaskConsumer implements LogEnabled {
eventReport.getIps().add("All"); eventReport.getIps().add("All");
content = eventReport.toString(); content = eventReport.toString();
} else if ("heartbeat".equals(reportName)) { } else if ("heartbeat".equals(reportName)) {
HeartbeatReport heartbeatReport = mergeHeartbeatReports(reportDomain, reports); // TODO
content = heartbeatReport.toString(); // HeartbeatReport heartbeatReport = mergeHeartbeatReports(reportDomain, reports);
// content = heartbeatReport.toString();
} else if ("problem".equals(reportName)) { } else if ("problem".equals(reportName)) {
ProblemReport problemReport = mergeProblemReports(reportDomain, reports); ProblemReport problemReport = mergeProblemReports(reportDomain, reports);
content = problemReport.toString(); content = problemReport.toString();
...@@ -219,8 +220,9 @@ public class DefaultTaskConsumer extends TaskConsumer implements LogEnabled { ...@@ -219,8 +220,9 @@ public class DefaultTaskConsumer extends TaskConsumer implements LogEnabled {
EventReport eventReport = mergeEventReports(reportDomain, reports); EventReport eventReport = mergeEventReports(reportDomain, reports);
graphs = splitEventReportToGraphs(reportPeriod, reportDomain, reportName, eventReport); graphs = splitEventReportToGraphs(reportPeriod, reportDomain, reportName, eventReport);
} else if ("heartbeat".equals(reportName)) { } else if ("heartbeat".equals(reportName)) {
HeartbeatReport heartbeatReport = mergeHeartbeatReports(reportDomain, reports); // TODO
graphs = splitHeartbeatReportToGraphs(reportPeriod, reportDomain, reportName, heartbeatReport); // HeartbeatReport heartbeatReport = mergeHeartbeatReports(reportDomain, reports);
// graphs = splitHeartbeatReportToGraphs(reportPeriod, reportDomain, reportName, heartbeatReport);
} else if ("problem".equals(reportName)) { } else if ("problem".equals(reportName)) {
ProblemReport problemReport = mergeProblemReports(reportDomain, reports); ProblemReport problemReport = mergeProblemReports(reportDomain, reports);
graphs = splitProblemReportToGraphs(reportPeriod, reportDomain, reportName, problemReport); graphs = splitProblemReportToGraphs(reportPeriod, reportDomain, reportName, problemReport);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册