@Test public void testAddPointLoop() throws InterruptedException { while (true) { long timestamp = System.currentTimeMillis(); String metric = "jvm_memory.Committed"; Map<String, String> tags = new HashMap<String, String>(); tags.put("APP", "trace"); tags.put("IP", "10.101.3.111"); long value = 10; MetricData metricData = MetricData.named(metric).withTags(tags).withValue(value).withTimestamp(timestamp).build(); storageRepository.save(metricData); TimeUnit.SECONDS.sleep(1); } }
public void save(TraceIndexTable appTable) { RepositoryFactory.getTraceIndexRepository().save(appTable); }
StorageRepository { public void save(TraceIndexTable appTable) { RepositoryFactory.getTraceIndexRepository().save(appTable); } }
StorageRepository { public void save(TraceIndexTable appTable) { RepositoryFactory.getTraceIndexRepository().save(appTable); }  }
StorageRepository { public void save(TraceIndexTable appTable) { RepositoryFactory.getTraceIndexRepository().save(appTable); }  static StorageRepository getStorageRepository(); void createHBaseTable(); void dropHBaseTable(); void initHBaseTable(); void save(TraceIndexTable appTable); void save(TraceOverviewTable traceTable); void save(Span span); void save(SystemData systemData); void save(ExceptionData exception); void save(MetricData metric); List<Map<String, Object>> findExceptionIndex(); List<ExceptionData> findExceptionData(Map<String, String> query); DataPoints[] find(long start,
                             String metric, Map<String, String> tags,
                             Aggregator function, boolean rate); DataPoints[] find(long start, long end,
                             String metric, Map<String, String> tags,
                             Aggregator function, boolean rate); List<Map<String, Object>> findSystemIndex(); SystemData findSystemData(Map<String, String> query); List<Map<String, Object>> findTraceIndex(); List<TraceOverviewTable> findTraceList(Map<String, String> query); Map<String, Integer> findSpanName(String traceId); List<Span> findTrace(String traceId); }
StorageRepository { public void save(TraceIndexTable appTable) { RepositoryFactory.getTraceIndexRepository().save(appTable); }  static StorageRepository getStorageRepository(); void createHBaseTable(); void dropHBaseTable(); void initHBaseTable(); void save(TraceIndexTable appTable); void save(TraceOverviewTable traceTable); void save(Span span); void save(SystemData systemData); void save(ExceptionData exception); void save(MetricData metric); List<Map<String, Object>> findExceptionIndex(); List<ExceptionData> findExceptionData(Map<String, String> query); DataPoints[] find(long start,
                             String metric, Map<String, String> tags,
                             Aggregator function, boolean rate); DataPoints[] find(long start, long end,
                             String metric, Map<String, String> tags,
                             Aggregator function, boolean rate); List<Map<String, Object>> findSystemIndex(); SystemData findSystemData(Map<String, String> query); List<Map<String, Object>> findTraceIndex(); List<TraceOverviewTable> findTraceList(Map<String, String> query); Map<String, Integer> findSpanName(String traceId); List<Span> findTrace(String traceId);  }