This is an automated email from the ASF dual-hosted git repository. dmvk pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git.
from 1eb2164 Merge pull request #8116: Update a guideline for commits history new b03de9e [BEAM-6875] expose timestampSkew to user in FlatMap#eventTimeBy new a3cc066 [BEAM-6875] add allowedTimestampSkew to AssignEventTime new ee7ce73 [BEAM-6875] require allowedTimestampSkew to be non null new 881dc9a [BEAM-6875] finalize implementation new 504de16 Merge pull request #8106: [BEAM-6875] expose timestampSkew to user in FlatMap#eventTimeBy The 20708 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: sdks/java/extensions/euphoria/build.gradle | 4 -- .../core/client/operator/AssignEventTime.java | 27 ++++++++++++- .../euphoria/core/client/operator/FlatMap.java | 44 ++++++++++++++++++++-- .../euphoria/core/translate/FlatMapTranslator.java | 15 +++++++- .../euphoria/core/client/operator/FlatMapTest.java | 25 ++++++++++++ 5 files changed, 103 insertions(+), 12 deletions(-)