Hi, When reading from a source with no timestamp specified on elements, what should be the default timestamp? I presume that it should be 0 as I saw PAssertTest trying to set timestamps to very small values with 0 allowed timestamp skew. Is that right?
What about the default watermark policy? If a ParDo modifies the timestamp using DoFnProcessContext.outputWithTimestamp, how should that affect the output watermark? Say the ParDo adds 100 seconds to the timestamp of each element in processElement, how could the runner know it should also add 100 seconds to output timestamps? Thanks, Shen
