Added toString() override in PartitionThroughputInfo (linkedin#858)

vmaheshw · Mar 1, 2022 · 45dd802 · 45dd802
1 parent 9e7b137
commit 45dd802
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/...ream-server-api/src/main/java/com/linkedin/datastream/server/PartitionThroughputInfo.java b/...ream-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);
+  }
 }