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