From 065ba62d2fcbb0b026aacce84f4659894502b34f Mon Sep 17 00:00:00 2001 From: Jhora Zakaryan Date: Thu, 21 Oct 2021 14:38:30 -0700 Subject: [PATCH] Added toString() override in PartitionThroughputInfo --- .../datastream/server/PartitionThroughputInfo.java | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/datastream-server-api/src/main/java/com/linkedin/datastream/server/PartitionThroughputInfo.java b/datastream-server-api/src/main/java/com/linkedin/datastream/server/PartitionThroughputInfo.java index 570e779fb..ed41065f0 100644 --- a/datastream-server-api/src/main/java/com/linkedin/datastream/server/PartitionThroughputInfo.java +++ b/datastream-server-api/src/main/java/com/linkedin/datastream/server/PartitionThroughputInfo.java @@ -48,4 +48,13 @@ public int getMessagesInRate() { public String getPartitionName() { return _partitionName; } + + /** + * {@inheritDoc} + */ + @Override + public String toString() { + return String.format("[PartitionName: %s, BytesInKBRate: %s, MessagesInRate: %s]", + _partitionName, _bytesInKBRate, _messagesInRate); + } }