[beam] branch master updated: [BEAM-10499] Adds a descriptive toString to SamzaRunner KeyedTimerData

[al...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

altay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 00d16aa  [BEAM-10499] Adds a descriptive toString to SamzaRunner KeyedTimerData
     new d5a6c2f  Merge pull request #12304 from Borzoo/beam-10499-nicer-tostring
00d16aa is described below

commit 00d16aa41d7c067abad93386816b642a23befcfc
Author: Borzoo <bo...@gmail.com>
AuthorDate: Fri Jul 17 21:34:40 2020 +0200

    [BEAM-10499] Adds a descriptive toString to SamzaRunner KeyedTimerData
---
 .../apache/beam/runners/samza/runtime/KeyedTimerData.java    | 12 ++++++++++++
 1 file changed, 12 insertions(+)

diff --git a/runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java b/runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java
index a7e364d..46dc95a 100644
--- a/runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java
+++ b/runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java
@@ -99,6 +99,18 @@ public class KeyedTimerData<K> implements Comparable<KeyedTimerData<K>> {
   }
 
   @Override
+  public String toString() {
+    return "KeyedTimerData{"
+        + "key="
+        + key
+        + ", keyBytes="
+        + Arrays.toString(keyBytes)
+        + ", timerData="
+        + timerData
+        + '}';
+  }
+
+  @Override
   public boolean equals(@Nullable Object o) {
     if (this == o) {
       return true;