public void addCsmLatencyByPartKey(String partitionKey, long dltTime) {
            PartitionStatsItemSet partStatsUnit = partDltStatsMap.get(partitionKey);
            if (partStatsUnit == null) {
                PartitionStatsItemSet tmpUnit = new PartitionStatsItemSet(partitionKey);
                partStatsUnit = partDltStatsMap.putIfAbsent(partitionKey, tmpUnit);
                if (partStatsUnit == null) {
                    partStatsUnit = tmpUnit;
                }
            }
            partStatsUnit.csmLatencyStats.update(dltTime);
        }
Accumulate consume latency information by partition

@param dltTime   the latency
inlong-tubemq/tubemq-client/src/main/java/org/apache/inlong/tubemq/client/common/ClientStatsInfo.java