Skip to content

Commit 247411a

Browse files
committed
1 parent b50153a commit 247411a

File tree

4 files changed

+8
-12
lines changed

4 files changed

+8
-12
lines changed

web/src/main/java/com/navercorp/pinpoint/web/applicationmap/dao/hbase/HbaseMapInLinkDao.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,6 @@
2828
import com.navercorp.pinpoint.web.applicationmap.dao.MapInLinkDao;
2929
import com.navercorp.pinpoint.web.applicationmap.dao.mapper.LinkTimeWindowReducer;
3030
import com.navercorp.pinpoint.web.applicationmap.dao.mapper.RowMapperFactory;
31-
import com.navercorp.pinpoint.web.applicationmap.link.LinkDirection;
3231
import com.navercorp.pinpoint.web.applicationmap.rawdata.LinkDataMap;
3332
import com.navercorp.pinpoint.web.applicationmap.rawdata.LinkDataMapUtils;
3433
import com.navercorp.pinpoint.web.mapper.RowMapReduceResultExtractor;
@@ -104,7 +103,7 @@ private LinkDataMap selectInLink(Scan scan, HbaseTable table, ResultsExtractor<L
104103
TableName inLinkTableName = tableNameProvider.getTableName(table);
105104
LinkDataMap linkDataMap = hbaseTemplate.findParallel(inLinkTableName, scan, rowKeyDistributor, resultExtractor, parallel);
106105
if (logger.isDebugEnabled()) {
107-
logger.debug("{} {} data: {}", LinkDirection.IN_LINK, inLinkTableName.getNameAsString(), linkDataMap);
106+
logger.debug("IN_LINK {} data: {}", inLinkTableName.getNameAsString(), linkDataMap);
108107
}
109108
if (LinkDataMapUtils.hasLength(linkDataMap)) {
110109
return linkDataMap;

web/src/main/java/com/navercorp/pinpoint/web/applicationmap/dao/hbase/HbaseMapOutLinkDao.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,6 @@
2828
import com.navercorp.pinpoint.web.applicationmap.dao.MapOutLinkDao;
2929
import com.navercorp.pinpoint.web.applicationmap.dao.mapper.LinkTimeWindowReducer;
3030
import com.navercorp.pinpoint.web.applicationmap.dao.mapper.RowMapperFactory;
31-
import com.navercorp.pinpoint.web.applicationmap.link.LinkDirection;
3231
import com.navercorp.pinpoint.web.applicationmap.rawdata.LinkDataMap;
3332
import com.navercorp.pinpoint.web.applicationmap.rawdata.LinkDataMapUtils;
3433
import com.navercorp.pinpoint.web.mapper.RowMapReduceResultExtractor;
@@ -102,7 +101,7 @@ private LinkDataMap selectOutLink(Scan scan, HbaseTable table, ResultsExtractor<
102101
TableName outLinkTableName = tableNameProvider.getTableName(table);
103102
LinkDataMap linkDataMap = this.hbaseTemplate.findParallel(outLinkTableName, scan, rowKeyDistributor, resultExtractor, parallel);
104103
if (logger.isDebugEnabled()) {
105-
logger.debug("{} {} data: {}", LinkDirection.OUT_LINK, outLinkTableName.getNameAsString(), linkDataMap);
104+
logger.debug("OUT_LINK {} data: {}", outLinkTableName.getNameAsString(), linkDataMap);
106105
}
107106
if (LinkDataMapUtils.hasLength(linkDataMap)) {
108107
return linkDataMap;

web/src/main/java/com/navercorp/pinpoint/web/applicationmap/dao/mapper/InLinkMapper.java

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,6 @@
2626
import com.navercorp.pinpoint.common.trace.ServiceType;
2727
import com.navercorp.pinpoint.common.util.TimeUtils;
2828
import com.navercorp.pinpoint.loader.service.ServiceTypeRegistryService;
29-
import com.navercorp.pinpoint.web.applicationmap.link.LinkDirection;
3029
import com.navercorp.pinpoint.web.applicationmap.rawdata.LinkDataMap;
3130
import com.navercorp.pinpoint.web.component.ApplicationFactory;
3231
import com.navercorp.pinpoint.web.vo.Application;
@@ -109,14 +108,14 @@ public LinkDataMap mapRow(Result result, int rowNum) throws Exception {
109108
}
110109

111110
if (logger.isDebugEnabled()) {
112-
logger.debug(" Fetched {}. {} outHost:{} -> {} (slot:{}/{}), ",
113-
LinkDirection.IN_LINK, in, outHost, inApplication, histogramSlot, requestCount);
111+
logger.debug(" Fetched IN_LINK {} outHost:{} -> {} (slot:{}/{})",
112+
in, outHost, inApplication, histogramSlot, requestCount);
114113
}
115114

116115
linkDataMap.addLinkData(in, in.getName(), inApplication, outHost, timestamp, histogramSlot, requestCount);
117116

118-
if (logger.isDebugEnabled()) {
119-
logger.debug(" Fetched {}. statistics:{}", LinkDirection.IN_LINK, linkDataMap);
117+
if (logger.isTraceEnabled()) {
118+
logger.trace(" Fetched IN_LINK inLink:{}", linkDataMap);
120119
}
121120
}
122121

web/src/main/java/com/navercorp/pinpoint/web/applicationmap/dao/mapper/OutLinkMapper.java

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,6 @@
2323
import com.navercorp.pinpoint.common.hbase.util.CellUtils;
2424
import com.navercorp.pinpoint.common.timeseries.window.TimeWindowFunction;
2525
import com.navercorp.pinpoint.common.util.TimeUtils;
26-
import com.navercorp.pinpoint.web.applicationmap.link.LinkDirection;
2726
import com.navercorp.pinpoint.web.applicationmap.rawdata.LinkDataMap;
2827
import com.navercorp.pinpoint.web.component.ApplicationFactory;
2928
import com.navercorp.pinpoint.web.vo.Application;
@@ -94,8 +93,8 @@ public LinkDataMap mapRow(Result result, int rowNum) throws Exception {
9493

9594
long requestCount = CellUtils.valueToLong(cell);
9695
if (logger.isDebugEnabled()) {
97-
logger.debug(" Fetched {}.(New) {} {} -> {} (slot:{}/{}) inHost:{}",
98-
LinkDirection.OUT_LINK, outApplication, outAgentId, inApplication, histogramSlot, requestCount, inHost);
96+
logger.debug(" Fetched OUT_LINK {} {} -> {} (slot:{}/{}) inHost:{}",
97+
outApplication, outAgentId, inApplication, histogramSlot, requestCount, inHost);
9998
}
10099

101100
if (StringUtils.isEmpty(inHost)) {

0 commit comments

Comments
 (0)