When using the direct runner to test and investigate streaming pipeline, it would be very convenient to display the watermark of each element to check if a window/trigger definition is correct.
Imported from Jira BEAM-3278. Original Jira may contain additional context.
Reported by: jbonofre.