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 <[email protected]>
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;