You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by gi...@apache.org on 2021/08/20 03:07:31 UTC
[beam] tag nightly-master updated (7587508 -> b0e9f26)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to tag nightly-master
in repository https://gitbox.apache.org/repos/asf/beam.git.
*** WARNING: tag nightly-master was modified! ***
from 7587508 (commit)
to b0e9f26 (commit)
from 7587508 Merge pull request #15307 from ihji/BEAM-12735
add 071fdc7 Removes test_bad_path
add 0ce5044 [BEAM-12775] Remove GCS dataflow badinput runner test #15350
add 2269f06 [BEAM-12754] Only call getValue once per field per row
add 4e05416 Merge pull request #15327: [BEAM-12754] Only call getValue once per field per row
add 358babb Fix broken BQ Integration Test (#15352)
add faeb062 Change conflicting StateReader name from side to reader (#15348)
add b0e9f26 [BEAM-3304] Go triggering support (#15239)
No new revisions were added by this update.
Summary of changes:
sdks/go/pkg/beam/core/graph/coder/coder.go | 6 +
sdks/go/pkg/beam/core/graph/coder/panes.go | 116 ++++++++++++++++++
sdks/go/pkg/beam/core/graph/edge.go | 6 +-
sdks/go/pkg/beam/core/graph/window/strategy.go | 18 ++-
sdks/go/pkg/beam/core/graph/window/trigger.go | 37 ++++++
sdks/go/pkg/beam/core/runtime/exec/coder.go | 62 +++++++---
sdks/go/pkg/beam/core/runtime/exec/datasink.go | 2 +-
sdks/go/pkg/beam/core/runtime/exec/datasource.go | 5 +-
.../pkg/beam/core/runtime/exec/datasource_test.go | 11 +-
.../go/pkg/beam/core/runtime/exec/dynsplit_test.go | 5 +-
sdks/go/pkg/beam/core/runtime/exec/fullvalue.go | 5 +-
sdks/go/pkg/beam/core/runtime/exec/pardo.go | 12 +-
sdks/go/pkg/beam/core/runtime/exec/reshuffle.go | 5 +-
sdks/go/pkg/beam/core/runtime/exec/window.go | 1 +
sdks/go/pkg/beam/core/runtime/graphx/translate.go | 129 +++++++++++++++++++--
sdks/go/pkg/beam/core/typex/class.go | 1 +
sdks/go/pkg/beam/core/typex/fulltype.go | 6 +
sdks/go/pkg/beam/core/typex/special.go | 16 +++
sdks/go/pkg/beam/pcollection.go | 1 -
.../beam/runners/dataflow/dataflowlib/translate.go | 3 +-
sdks/go/pkg/beam/windowing.go | 37 +++++-
sdks/go/test/integration/integration.go | 12 ++
sdks/go/test/integration/primitives/windowinto.go | 91 ++++++++++++++-
.../test/integration/primitives/windowinto_test.go | 28 +++++
.../apache/beam/sdk/coders/RowCoderGenerator.java | 49 +++++---
.../apache_beam/io/gcp/bigquery_write_it_test.py | 9 +-
.../runners/dataflow/template_runner_test.py | 21 ----
27 files changed, 602 insertions(+), 92 deletions(-)
create mode 100644 sdks/go/pkg/beam/core/graph/coder/panes.go
create mode 100644 sdks/go/pkg/beam/core/graph/window/trigger.go