Abacn commented on PR #33614: URL: https://github.com/apache/beam/pull/33614#issuecomment-2605802955
Thanks for the fix. There might be something need clarification here. TimestampedValue is a special value type in Beam. If an element wrapped as a TimestampedValue, in downstream the timestamp becomes a metadata for this element, while the element is still the original one, e.g. ``` _ = p | beam.Create(["1", "2", "3"]) | beam.Map(lambda x: window.TimestampedValue(x, timestamp.MAX_TIMESTAMP)) | beam.Map(print) presult = p.run() ``` it prints the str itself instead of TimestampedValue(1) Seems this convention conflicts with type check also part of Beam SDK. cc: @jrmccluskey @tvalentyn may have a solution here -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
