From ac8df49302ac602fa88bdacb41de4cc83d2417fd Mon Sep 17 00:00:00 2001
From: Chisu Yu <puseori9th@gmail.com>
Date: Mon, 25 Feb 2013 06:00:27 +0000
Subject: [PATCH] =?UTF-8?q?[=EC=9C=A0=EC=B9=98=EC=88=98]=20[NOBTS]=20roott?=
 =?UTF-8?q?raceindex=20=EC=A0=9C=EA=B1=B0.?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

git-svn-id: http://svn.bds.nhncorp.com/pe/hippo-web/trunk@1252 84d0f5b1-2673-498c-a247-62c4ff18d310
---
 .../nhn/hippo/web/dao/RootTraceIndexDao.java  | 15 ----
 .../web/dao/hbase/HbaseRootTraceIndexDao.java | 82 -------------------
 2 files changed, 97 deletions(-)
 delete mode 100644 src/main/java/com/nhn/hippo/web/dao/RootTraceIndexDao.java
 delete mode 100644 src/main/java/com/nhn/hippo/web/dao/hbase/HbaseRootTraceIndexDao.java

diff --git a/src/main/java/com/nhn/hippo/web/dao/RootTraceIndexDao.java b/src/main/java/com/nhn/hippo/web/dao/RootTraceIndexDao.java
deleted file mode 100644
index 7ea2d0b43..000000000
--- a/src/main/java/com/nhn/hippo/web/dao/RootTraceIndexDao.java
+++ /dev/null
@@ -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);
-}
diff --git a/src/main/java/com/nhn/hippo/web/dao/hbase/HbaseRootTraceIndexDao.java b/src/main/java/com/nhn/hippo/web/dao/hbase/HbaseRootTraceIndexDao.java
deleted file mode 100644
index 473c3ce66..000000000
--- a/src/main/java/com/nhn/hippo/web/dao/hbase/HbaseRootTraceIndexDao.java
+++ /dev/null
@@ -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.
-	}
-}