mirror of
https://github.com/wahyd4/pinpoint.git
synced 2026-08-17 16:56:15 +10:00
[유치수] [NOBTS] 불필요한 코드 제거.
git-svn-id: http://svn.bds.nhncorp.com/pe/hippo-web/trunk@1260 84d0f5b1-2673-498c-a247-62c4ff18d310
This commit is contained in:
@@ -1,18 +1,18 @@
|
||||
package com.nhn.hippo.web.dao.hbase;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
import org.apache.hadoop.hbase.client.Get;
|
||||
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.ApiMetaDataDao;
|
||||
import com.nhn.hippo.web.mapper.ApiMetaDataMapper;
|
||||
import com.profiler.common.bo.ApiMetaDataBo;
|
||||
import com.profiler.common.hbase.HBaseTables;
|
||||
import com.profiler.common.hbase.HbaseOperations2;
|
||||
import com.profiler.common.util.RowKeyUtils;
|
||||
import org.apache.hadoop.hbase.client.Get;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.stereotype.Repository;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
*
|
||||
@@ -20,13 +20,12 @@ import java.util.List;
|
||||
@Repository
|
||||
public class HbaseApiMetaDataDao implements ApiMetaDataDao {
|
||||
|
||||
private final Logger logger = LoggerFactory.getLogger(this.getClass());
|
||||
|
||||
@Autowired
|
||||
private HbaseOperations2 hbaseOperations2;
|
||||
|
||||
@Autowired
|
||||
private ApiMetaDataMapper mapper;
|
||||
@Qualifier("apiMetaDataMapper")
|
||||
private RowMapper<List<ApiMetaDataBo>> apiMetaDataMapper;
|
||||
|
||||
@Override
|
||||
public List<ApiMetaDataBo> getApiMetaData(String agentId, short identifier, int apiId, long time) {
|
||||
@@ -34,6 +33,6 @@ public class HbaseApiMetaDataDao implements ApiMetaDataDao {
|
||||
Get get = new Get(sqlId);
|
||||
get.addFamily(HBaseTables.API_METADATA_CF_API);
|
||||
|
||||
return hbaseOperations2.get(HBaseTables.API_METADATA, get, mapper);
|
||||
return hbaseOperations2.get(HBaseTables.API_METADATA, get, apiMetaDataMapper);
|
||||
}
|
||||
}
|
||||
|
||||
@@ -1,18 +1,18 @@
|
||||
package com.nhn.hippo.web.dao.hbase;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
import org.apache.hadoop.hbase.client.Get;
|
||||
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.SqlMetaDataDao;
|
||||
import com.nhn.hippo.web.mapper.SqlMetaDataMapper;
|
||||
import com.profiler.common.bo.SqlMetaDataBo;
|
||||
import com.profiler.common.hbase.HBaseTables;
|
||||
import com.profiler.common.hbase.HbaseOperations2;
|
||||
import com.profiler.common.util.RowKeyUtils;
|
||||
import org.apache.hadoop.hbase.client.Get;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.stereotype.Repository;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
*
|
||||
@@ -20,13 +20,12 @@ import java.util.List;
|
||||
@Repository
|
||||
public class HbaseSqlMetaDataDao implements SqlMetaDataDao {
|
||||
|
||||
private final Logger logger = LoggerFactory.getLogger(this.getClass());
|
||||
|
||||
@Autowired
|
||||
private HbaseOperations2 hbaseOperations2;
|
||||
|
||||
@Autowired
|
||||
private SqlMetaDataMapper mapper;
|
||||
@Qualifier("sqlMetaDataMapper")
|
||||
private RowMapper<List<SqlMetaDataBo>> sqlMetaDataMapper;
|
||||
|
||||
@Override
|
||||
public List<SqlMetaDataBo> getSqlMetaData(String agentId, short identifier, int hashCode, long time) {
|
||||
@@ -34,6 +33,6 @@ public class HbaseSqlMetaDataDao implements SqlMetaDataDao {
|
||||
Get get = new Get(sqlId);
|
||||
get.addFamily(HBaseTables.SQL_METADATA_CF_SQL);
|
||||
|
||||
return hbaseOperations2.get(HBaseTables.SQL_METADATA, get, mapper);
|
||||
return hbaseOperations2.get(HBaseTables.SQL_METADATA, get, sqlMetaDataMapper);
|
||||
}
|
||||
}
|
||||
|
||||
@@ -35,13 +35,13 @@ public class HbaseTerminalStatisticsDao implements TerminalStatisticsDao {
|
||||
private HbaseOperations2 hbaseOperations2;
|
||||
|
||||
@Autowired
|
||||
@Qualifier("terminalRequestCountMapper")
|
||||
private RowMapper<Map<String, TerminalStatistics>> terminalRequestCountMapper;
|
||||
@Qualifier("terminalStatisticsMapper")
|
||||
private RowMapper<Map<String, TerminalStatistics>> terminalStatisticsMapper;
|
||||
|
||||
@Override
|
||||
public List<Map<String, TerminalStatistics>> selectTerminal(String applicationName, long from, long to) {
|
||||
Scan scan = createScan(applicationName, from, to);
|
||||
return hbaseOperations2.find(HBaseTables.TERMINAL_STATISTICS, scan, terminalRequestCountMapper);
|
||||
return hbaseOperations2.find(HBaseTables.TERMINAL_STATISTICS, scan, terminalStatisticsMapper);
|
||||
}
|
||||
|
||||
private Scan createScan(String applicationName, long from, long to) {
|
||||
|
||||
@@ -1,6 +1,5 @@
|
||||
package com.nhn.hippo.web.mapper;
|
||||
|
||||
import com.profiler.common.util.BytesUtils;
|
||||
import org.apache.hadoop.hbase.client.Result;
|
||||
import org.apache.hadoop.hbase.util.Bytes;
|
||||
import org.springframework.data.hadoop.hbase.RowMapper;
|
||||
|
||||
@@ -4,7 +4,8 @@ package com.nhn.hippo.web.service;
|
||||
*
|
||||
*/
|
||||
public class AgentIdNotFoundException extends RuntimeException {
|
||||
private String agentId;
|
||||
private static final long serialVersionUID = -2017517623014042821L;
|
||||
private String agentId;
|
||||
private long startTime;
|
||||
|
||||
public AgentIdNotFoundException(String agentId, long startTime) {
|
||||
|
||||
@@ -1,7 +1,6 @@
|
||||
package com.nhn.hippo.web.vo;
|
||||
|
||||
import java.util.ArrayList;
|
||||
import java.util.Collections;
|
||||
import java.util.HashMap;
|
||||
import java.util.HashSet;
|
||||
import java.util.List;
|
||||
|
||||
Reference in New Issue
Block a user