Hi, Say I want to replay a data trace of last week using fixed windows. The data trace is read from a file using TextIO. In order to trigger windows at right times, how can I control the watermark emitted by the BoundedSource?
Thanks, Shen
Hi, Say I want to replay a data trace of last week using fixed windows. The data trace is read from a file using TextIO. In order to trigger windows at right times, how can I control the watermark emitted by the BoundedSource?
Thanks, Shen