Hi All,

I saw that in the Python SDK we encode WindowedValues
<https://github.com/apache/beam/blob/b4f02888aed20f6f066d07f4ff26e6688a6f848e/sdks/python/apache_beam/coders/coder_impl.py#L1082>
and Timestamps
<https://github.com/apache/beam/blob/b4f02888aed20f6f066d07f4ff26e6688a6f848e/sdks/python/apache_beam/coders/coder_impl.py#L598>
as millis, whereas the TIME_GRANULARITY
<https://github.com/apache/beam/blob/master/sdks/python/apache_beam/utils/timestamp.py#L418>
is defined as 1us. Why do we do this? Won't this cause problems using the
FnApiRunner as windows might fire out of order or something else?

Thanks,
Sam

Reply via email to