The goal is to have the max global window timestamp _once_ defined globally across all sdks. `beam-model-pipeline` is the proto definition which all SDKs depend on.
In Python the module structure is much simpler and we just have the proto always available. In java, due to the runners being in java, we have a separate `beam-sds-java-core` module which so far doesn't depend on the pipeline module. We have two options 1) depend on the pipeline definition in java-core 2) move GlobalWindow from java-core (I found this to be pretty tricky). You propose to factor out the timestamp into a new module and let all sdks depend on that? [ Full content available at: https://github.com/apache/beam/pull/6381 ] This message was relayed via gitbox.apache.org for [email protected]
