This is an automated email from the ASF dual-hosted git repository.
yhu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from 3b7e1dcc4e6 Typescript changes for Beam 2.51.0 (#28553)
add 534f93acd18 Introduce PeriodicImpulse.stopAfter() (#28503)
No new revisions were added by this update.
Summary of changes:
.../beam/runners/dataflow/DataflowRunner.java | 2 +-
.../beam/sdk/transforms/PeriodicImpulse.java | 98 ++++++++++++++++++----
.../beam/sdk/transforms/PeriodicSequence.java | 3 +
.../io/gcp/bigquery/BigQueryIOStorageWriteIT.java | 42 ++++++++--
4 files changed, 123 insertions(+), 22 deletions(-)