diff --git a/src/main/java/com/nhn/hippo/web/dao/ApplicationsIndex.java b/src/main/java/com/nhn/hippo/web/dao/ApplicationsIndex.java new file mode 100644 index 000000000..3a1213042 --- /dev/null +++ b/src/main/java/com/nhn/hippo/web/dao/ApplicationsIndex.java @@ -0,0 +1,5 @@ +package com.nhn.hippo.web.dao; + +public interface ApplicationsIndex { + public void getAgentIds(String applicationName); +} diff --git a/src/main/java/com/nhn/hippo/web/dao/HbaseApplicationsIndexDao.java b/src/main/java/com/nhn/hippo/web/dao/HbaseApplicationsIndexDao.java new file mode 100644 index 000000000..124c8045d --- /dev/null +++ b/src/main/java/com/nhn/hippo/web/dao/HbaseApplicationsIndexDao.java @@ -0,0 +1,19 @@ +package com.nhn.hippo.web.dao; + +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.annotation.Autowired; + +import com.profiler.common.hbase.HbaseOperations2; + +public class HbaseApplicationsIndexDao implements ApplicationsIndex { + private final Logger logger = LoggerFactory.getLogger(this.getClass().getName()); + + @Autowired + private HbaseOperations2 hbaseTemplate; + + @Override + public void getAgentIds(String applicationName) { + + } +} diff --git a/src/main/java/com/nhn/hippo/web/service/FlowChartServiceImpl.java b/src/main/java/com/nhn/hippo/web/service/FlowChartServiceImpl.java index f81a69d91..e15ec64a3 100755 --- a/src/main/java/com/nhn/hippo/web/service/FlowChartServiceImpl.java +++ b/src/main/java/com/nhn/hippo/web/service/FlowChartServiceImpl.java @@ -45,7 +45,7 @@ public class FlowChartServiceImpl implements FlowChartService { List column = new ArrayList(); column.add(new HbaseColumn("Agents", "AgentID")); - HBaseQuery query = new HBaseQuery(HBaseTables.SERVERS, null, null, column); + HBaseQuery query = new HBaseQuery(HBaseTables.APPLICATIONS_INDEX, null, null, column); Iterator> iterator = client.getHBaseData(query); if (logger.isDebugEnabled()) {