Log size partition cost

[wycccccc]

#553 從其中切割出，爲NodeTopicSize加入partition cost。

[chia7712]

@wycccccc 概念很不錯，不過程式碼風格要調整一下，請參考我給的建議去調整，謝謝

[chia7712]

這一段也是重複的程式碼：

    Function<Map.Entry<TopicPartition, Collection<HasBeanObject>>, Double> toDouble =
        e ->
            LogMetrics.Log.meters(e.getValue(), LogMetrics.Log.SIZE).stream()
                .mapToDouble(HasValue::value)
                .findAny()
                .orElse(0.0D);

[wycccccc]

太不敏感了，已修正。

[qoo332001]

這邊用mapByReplica比較適合，因為mapByReplica才會針對所有的replica去撈資料，mapByPartition一個partition只會撈一筆而已，可能不會考慮到replica還沒sync完成的狀態

[wycccccc]

因爲mapByReplica的存在，我一開始認爲mapByPartition會回傳的是leader partition。但看了一下實做發現並不是。已將partitionCost修改爲該方法應該有的樣子。
另外我感覺mapByPartition的設計似乎缺少明確的意義，它似乎只是一個劣化版的mapByReplica，不如把它修改成回傳leader partition 或者直接移除。

[chia7712]

另外我感覺mapByPartition的設計似乎缺少明確的意義，它似乎只是一個劣化版的mapByReplica，不如把它修改成回傳leader partition 或者直接移除。

同意，mapByPartition似乎可以被mapByReplica所取代

@qoo332001 你覺得呢？

[chia7712]

@wycccccc 感謝更新，一樣有幾個建議請看一下

[chia7712]

        var replicas =
            clusterInfo.availableReplicaLeaders(topic).stream()
                .map(r -> TopicPartitionReplica.of(r.topic(), r.partition(), r.nodeInfo().id()))
                .collect(Collectors.toUnmodifiableSet());
        return clusterBean.mapByReplica().entrySet().stream()
            .filter(
                topicPartitionCollectionEntry ->
                    replicas.contains(topicPartitionCollectionEntry.getKey()))
            .collect(
                Collectors.toMap(
                    topicPartitionCollectionEntry ->
                        TopicPartition.of(
                            topicPartitionCollectionEntry.getKey().topic(),
                            topicPartitionCollectionEntry.getKey().partition()),
                    topicPartitionCollectionEntry ->
                        toDouble.apply(topicPartitionCollectionEntry)));

這樣如何？

[wycccccc]

這樣確實更簡潔了，已修改成此邏輯。

[chia7712]

麻煩加上private final

[wycccccc]

done

[chia7712]

toDouble 加上 private final 後就可以簡化成toDouble

[wycccccc]

done

[chia7712]

toDouble 加上 private final 後就可以簡化成toDouble

[wycccccc]

done