| commit | d5a6c2f0ceb7b3e609ba8d97e523b3bded7d0459 | [log] [tgz] |
|---|---|---|
| author | Ahmet Altay <aaltay@gmail.com> | Mon Aug 03 16:39:04 2020 -0700 |
| committer | GitHub <noreply@github.com> | Mon Aug 03 16:39:04 2020 -0700 |
| tree | 0754db2f528525d23a923c5cf3750a519a375fb6 | |
| parent | 29ea00e7cbbb6387f6b0c6ee8b112802d1559851 [diff] | |
| parent | 00d16aa41d7c067abad93386816b642a23befcfc [diff] |
Merge pull request #12304 from Borzoo/beam-10499-nicer-tostring [BEAM-10499] Adds a descriptive toString to SamzaRunner KeyedTimerData
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 @@ } @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;