mirror of
https://github.com/wahyd4/pinpoint.git
synced 2026-08-23 19:56:59 +10:00
[강운덕] [LUCYSUS-1744] 향후 HBaseTables는 별도 패키로 빠져서 hbase단위로 분리될 예정이므로 PinpointConstants를 참조 하도록 변경함.
git-svn-id: http://svn.bds.nhncorp.com/pe/hippo-web/trunk@2400 84d0f5b1-2673-498c-a247-62c4ff18d310
This commit is contained in:
@@ -1,7 +1,7 @@
|
||||
package com.nhn.pinpoint.web.mapper;
|
||||
|
||||
import com.nhn.pinpoint.common.PinpointConstants;
|
||||
import com.nhn.pinpoint.common.bo.AgentInfoBo;
|
||||
import com.nhn.pinpoint.common.hbase.HBaseTables;
|
||||
import com.nhn.pinpoint.common.util.BytesUtils;
|
||||
import com.nhn.pinpoint.common.util.TimeUtils;
|
||||
import org.apache.hadoop.hbase.KeyValue;
|
||||
@@ -43,10 +43,10 @@ public class AgentInfoMapper implements RowMapper<List<AgentInfoBo>> {
|
||||
agentInfoBo.readValue(keyValue.getValue());
|
||||
|
||||
byte[] rowKey = keyValue.getRow();
|
||||
String agentId = Bytes.toString(rowKey, 0, HBaseTables.AGENT_NAME_MAX_LEN - 1).trim();
|
||||
String agentId = Bytes.toString(rowKey, 0, PinpointConstants.AGENT_NAME_MAX_LEN - 1).trim();
|
||||
agentInfoBo.setAgentId(agentId);
|
||||
|
||||
long reverseStartTime = BytesUtils.bytesToLong(rowKey, HBaseTables.AGENT_NAME_MAX_LEN);
|
||||
long reverseStartTime = BytesUtils.bytesToLong(rowKey, PinpointConstants.AGENT_NAME_MAX_LEN);
|
||||
long startTime = TimeUtils.recoveryCurrentTimeMillis(reverseStartTime);
|
||||
agentInfoBo.setStartTime(startTime);
|
||||
|
||||
|
||||
@@ -1,7 +1,6 @@
|
||||
package com.nhn.pinpoint.web.vo;
|
||||
|
||||
import com.nhn.pinpoint.common.PinpointConstants;
|
||||
import com.nhn.pinpoint.common.hbase.HBaseTables;
|
||||
import com.nhn.pinpoint.common.util.BytesUtils;
|
||||
import com.nhn.pinpoint.common.util.TransactionIdUtils;
|
||||
|
||||
@@ -72,7 +71,7 @@ public class TransactionId {
|
||||
}
|
||||
|
||||
public byte[] getBytes() {
|
||||
return BytesUtils.stringLongLongToBytes(agentId, HBaseTables.AGENT_NAME_MAX_LEN, agentStartTime, transactionSequence);
|
||||
return BytesUtils.stringLongLongToBytes(agentId, PinpointConstants.AGENT_NAME_MAX_LEN, agentStartTime, transactionSequence);
|
||||
}
|
||||
|
||||
@Override
|
||||
|
||||
Reference in New Issue
Block a user