home/pinpoint
2
0
Fork 0
mirror of https://github.com/wahyd4/pinpoint.git synced 2026-08-17 00:36:02 +10:00
Code Issues Packages Projects Releases Wiki Activity

[유치수] [NOBTS] roottraceindex 제거.

Browse Source 
git-svn-id: http://svn.bds.nhncorp.com/pe/hippo-web/trunk@1252 84d0f5b1-2673-498c-a247-62c4ff18d310
This commit is contained in:
Chisu Yu
2013-02-25 06:00:27 +00:00
parent 43f46dabc9
commit ac8df49302
2 changed files with 0 additions and 97 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/nhn/hippo/web/dao/RootTraceIndexDao.java
-15
View File
@@ -1,15 +0,0 @@
package com.nhn.hippo.web.dao;
import java.util.List;
/**
* root trace index가 필요 없을것 같음.
*/
@Deprecated
public interface RootTraceIndexDao {
List<List<byte[]>> scanTraceIndex(String agent, long start, long end);
List<List<List<byte[]>>> multiScanTraceIndex(String[] agents, long start, long end);
List<List<List<byte[]>>> parallelScanTraceIndex(String[] agents, long start, long end);
}
src/main/java/com/nhn/hippo/web/dao/hbase/HbaseRootTraceIndexDao.java
-82
View File
@@ -1,82 +0,0 @@
package com.nhn.hippo.web.dao.hbase;
import java.util.ArrayList;
import java.util.List;
import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.util.Bytes;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.data.hadoop.hbase.RowMapper;
import org.springframework.stereotype.Repository;
import com.nhn.hippo.web.dao.RootTraceIndexDao;
import com.profiler.common.hbase.HBaseTables;
import com.profiler.common.hbase.HbaseOperations2;
import com.profiler.common.util.SpanUtils;
/**
* root trace index가 필요 없을것 같음.
*/
@Deprecated
@Repository
public class HbaseRootTraceIndexDao implements RootTraceIndexDao {
private Logger logger = LoggerFactory.getLogger(this.getClass());
@Autowired
private HbaseOperations2 hbaseOperations2;
@Autowired
@Qualifier("traceIndexMapper")
private RowMapper<List<byte[]>> traceIndexMapper;
private int scanCacheSize = 40;
public void setScanCacheSize(int scanCacheSize) {
this.scanCacheSize = scanCacheSize;
}
@Override
public List<List<byte[]>> scanTraceIndex(String agent, long start, long end) {
Scan scan = createScan(agent, start, end);
return hbaseOperations2.find(HBaseTables.ROOT_TRACE_INDEX, scan, traceIndexMapper);
}
@Override
public List<List<List<byte[]>>> multiScanTraceIndex(String[] agents, long start, long end) {
final List<Scan> multiScan = new ArrayList<Scan>(agents.length);
for (String agent : agents) {
Scan scan = createScan(agent, start, end);
multiScan.add(scan);
}
return hbaseOperations2.find(HBaseTables.ROOT_TRACE_INDEX, multiScan, traceIndexMapper);
}
private Scan createScan(String agent, long start, long end) {
Scan scan = new Scan();
// cache size를 지정해야 되는거 같음.??
scan.setCaching(this.scanCacheSize);
byte[] bAgent = Bytes.toBytes(agent);
byte[] traceIndexStartKey = SpanUtils.getTraceIndexRowKey(bAgent, start);
scan.setStartRow(traceIndexStartKey);
byte[] traceIndexEndKey = SpanUtils.getTraceIndexRowKey(bAgent, end);
scan.setStopRow(traceIndexEndKey);
scan.addFamily(HBaseTables.ROOT_TRACE_INDEX_CF_TRACE);
scan.setId("rootTraceIndexScan");
// json으로 변화해서 로그를 찍어서. 최초 변환 속도가 느림.
logger.debug("create scan:{}", scan);
return scan;
}
@Override
public List<List<List<byte[]>>> parallelScanTraceIndex(String[] agents, long start, long end) {
return null; // To change body of implemented methods use File |
// Settings | File Templates.
}
}