in src/main/java/org/apache/pulsar/manager/mapper/TopicsStatsMapper.java [106:124]
Page<TopicStatsEntity> findByMultiTenant(
@Param("environment") String environment,
@Param("tenantList") List<String> tenantList,
@Param("timestamp") long timestamp);
@Select({"<script>",
"SELECT environment, tenant, namespace,"
+ "sum(producer_count) as producerCount,"
+ "sum(subscription_count) as subscriptionCount,"
+ "sum(msg_rate_in) as msgRateIn,"
+ "sum(msg_throughput_in) as msgThroughputIn,"
+ "sum(msg_rate_out) as msgRateOut,"
+ "sum(msg_throughput_out) as msgThroughputOut,"
+ "avg(average_msg_size) as averageMsgSize,"
+ "sum(storage_size) as storageSize, time_stamp FROM topics_stats",
"WHERE environment=#{environment} and tenant=#{tenant} and time_stamp=#{timestamp} and " +
"namespace IN <foreach collection='namespaceList' item='namespace' open='(' separator=',' close=')'> #{namespace} </foreach>" +
"GROUP BY environment, tenant, namespace, time_stamp" +
"</script>"})