[refactor][tests] Expanded toString for TestEventSource

akalash · dawidwys · commit 63bd6a382807 · 2021-10-22T12:24:46.000+02:00
diff --git a/flink-tests/src/test/java/org/apache/flink/runtime/operators/lifecycle/event/OperatorFinishedEvent.java b/flink-tests/src/test/java/org/apache/flink/runtime/operators/lifecycle/event/OperatorFinishedEvent.java
@@ -50,9 +50,19 @@ public long getLastReceived(String upstreamID, int upstreamIndex) {
         return receiveInfo.forUpstream(upstreamID).getOrDefault(upstreamIndex, -1L);
     }
 
+    @Override
+    public String toString() {
+        return String.format("%s; receive=%s; sent=%d", super.toString(), receiveInfo, lastSent);
+    }
+
     /** LastVertexDataInfo. */
     public static class LastVertexDataInfo implements Serializable {
         public final Map<Integer, Long> bySubtask = new HashMap<>();
+
+        @Override
+        public String toString() {
+            return String.valueOf(bySubtask);
+        }
     }
 
     /** LastReceivedVertexDataInfo. */
@@ -67,5 +77,10 @@ public Map<Integer, Long> forUpstream(String upstreamID) {
             return byUpstreamOperatorID.getOrDefault(upstreamID, new LastVertexDataInfo())
                     .bySubtask;
         }
+
+        @Override
+        public String toString() {
+            return String.valueOf(byUpstreamOperatorID);
+        }
     }
 }

Original file line number	Diff line number	Diff line change
`@@ -50,9 +50,19 @@ public long getLastReceived(String upstreamID, int upstreamIndex) {`
`50`	`50`	`return receiveInfo.forUpstream(upstreamID).getOrDefault(upstreamIndex, -1L);`
`51`	`51`	`}`
`52`	`52`
	`53`	`+ @Override`
	`54`	`+ public String toString() {`
	`55`	`+ return String.format("%s; receive=%s; sent=%d", super.toString(), receiveInfo, lastSent);`
	`56`	`+ }`
	`57`	`+`
`53`	`58`	`/** LastVertexDataInfo. */`
`54`	`59`	`public static class LastVertexDataInfo implements Serializable {`
`55`	`60`	`public final Map<Integer, Long> bySubtask = new HashMap<>();`
	`61`	`+`
	`62`	`+ @Override`
	`63`	`+ public String toString() {`
	`64`	`+ return String.valueOf(bySubtask);`
	`65`	`+ }`
`56`	`66`	`}`
`57`	`67`
`58`	`68`	`/** LastReceivedVertexDataInfo. */`
`@@ -67,5 +77,10 @@ public Map<Integer, Long> forUpstream(String upstreamID) {`
`67`	`77`	`return byUpstreamOperatorID.getOrDefault(upstreamID, new LastVertexDataInfo())`
`68`	`78`	`.bySubtask;`
`69`	`79`	`}`
	`80`	`+`
	`81`	`+ @Override`
	`82`	`+ public String toString() {`
	`83`	`+ return String.valueOf(byUpstreamOperatorID);`
	`84`	`+ }`
`70`	`85`	`}`
`71`	`86`	`}`