[#9254] Collects and retrieves URL statistics using Pinot

collector/src/main/java/com/navercorp/pinpoint/collector/mapper/grpc/stat/GrpcAgentUriStatMapper.java

@@ -40,11 +40,14 @@ public AgentUriStatBo map(final PAgentUriStat agentUriStat) {
 
         final String agentId = agentInfo.getAgentId();
         final long startTimestamp = agentInfo.getAgentStartTime();
+        final String applicationName = agentInfo.getApplicationName();
 
         long timestamp = agentUriStat.getTimestamp();
         int bucketVersion = agentUriStat.getBucketVersion();
 
         AgentUriStatBo agentUriStatBo = new AgentUriStatBo();
+        agentUriStatBo.setServiceName("");                        // TODO: add serviceName when available
+        agentUriStatBo.setApplicationName(applicationName);
         agentUriStatBo.setAgentId(agentId);
         agentUriStatBo.setStartTimestamp(startTimestamp);
         agentUriStatBo.setTimestamp(timestamp);
@@ -82,7 +85,7 @@ private UriStatHistogram convertUriStatHistogram(PUriHistogram pUriHistogram) {
             return null;
         }
 
-        double avg = pUriHistogram.getAvg();
+        long total = pUriHistogram.getTotal();
         long max = pUriHistogram.getMax();
 
         int histogramCount = pUriHistogram.getHistogramCount();
@@ -95,7 +98,7 @@ private UriStatHistogram convertUriStatHistogram(PUriHistogram pUriHistogram) {
 
         UriStatHistogram uriStatHistogram = new UriStatHistogram();
         uriStatHistogram.setCount(count);
-        uriStatHistogram.setAvg(avg);
+        uriStatHistogram.setTotal(total);
         uriStatHistogram.setMax(max);
         uriStatHistogram.setTimestampHistogram(histogram);
 

collector/src/main/java/com/navercorp/pinpoint/collector/service/HBaseAgentUriStatService.java → collector/src/main/java/com/navercorp/pinpoint/collector/service/EmptyAgentUriStatService.java

@@ -16,28 +16,17 @@
 
 package com.navercorp.pinpoint.collector.service;
 
-import com.navercorp.pinpoint.collector.dao.hbase.HbaseAgentUriStatDao;
 import com.navercorp.pinpoint.common.server.bo.stat.AgentUriStatBo;
 
+import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
 import org.springframework.stereotype.Service;
 
-import java.util.Objects;
-
 /**
  * @author Taejin Koo
  */
-@Service("hBaseAgentUriStatService")
-public class HBaseAgentUriStatService implements AgentUriStatService {
-
-    private final HbaseAgentUriStatDao hbaseAgentUriStatDao;
-
-    public HBaseAgentUriStatService(HbaseAgentUriStatDao hbaseAgentUriStatDao) {
-        this.hbaseAgentUriStatDao = Objects.requireNonNull(hbaseAgentUriStatDao, "hbaseAgentUriStatDao");
-    }
-
+@ConditionalOnMissingBean(value = AgentUriStatService.class, ignored = EmptyAgentUriStatService.class)
+@Service
+public class EmptyAgentUriStatService implements AgentUriStatService {
     @Override
-    public void save(AgentUriStatBo agentUriStatBo) {
-        hbaseAgentUriStatDao.insert(agentUriStatBo);
-    }
-
+    public void save(AgentUriStatBo agentUriStatBo) {}
 }

commons-server/src/main/java/com/navercorp/pinpoint/common/server/bo/codec/stat/AgentStatCoderConfiguration.java

@@ -162,16 +162,4 @@ public AgentStatDecoder<TransactionBo> getAgentTransactionDecoder(List<AgentStat
     public AgentStatEncoder<TransactionBo> getAgentTransactionEncoder(AgentStatCodec<TransactionBo> codec) {
         return new AgentStatEncoder<>(codec);
     }
-
-    // ----------------
-
-    @Bean
-    public AgentStatDecoder<AgentUriStatBo> getAgentAgentUriStatDecoder(List<AgentStatCodec<AgentUriStatBo>> codecs) {
-        return new AgentStatDecoder<>(codecs);
-    }
-
-    @Bean
-    public AgentStatEncoder<AgentUriStatBo> getAgentAgentUriStatEncoder(AgentStatCodec<AgentUriStatBo> codec) {
-        return new AgentStatEncoder<>(codec);
-    }
 }