This is an automated email from the ASF dual-hosted git repository.
jaku pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 4b4381a Merge pull request #5404 from akedin/fix-maven-build-1
add 091da44 Add Go integration tests
new c1927cd Merge pull request #5326: [BEAM-3827] Add Go integration tests
The 1 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:
.../windowed_wordcount/windowed_wordcount.go | 2 +-
.../filesystem/{local/local.go => memfs/memory.go} | 76 ++++++++++++++---
.../go/pkg/beam/io/filesystem/memfs/memory_test.go | 74 ++++++++++++++++
.../{log/standard.go => io/filesystem/util.go} | 34 +++++---
sdks/go/pkg/beam/options/jobopts/options.go | 9 +-
sdks/go/pkg/beam/runners/dataflow/dataflow.go | 23 ++---
.../beam/runners/universal/runnerlib/compile.go | 8 +-
.../beam/runners/universal/runnerlib/execute.go | 9 +-
sdks/go/pkg/beam/testing/passert/hash.go | 69 +++++++++++++++
sdks/go/pkg/beam/util.go | 6 ++
sdks/go/pkg/beam/x/hooks/perf/perf.go | 2 +-
sdks/go/test/integration/driver.go | 98 ++++++++++++++++++++++
.../integration}/wordcount/wordcount.go | 48 ++++++++---
.../integration/wordcount/wordcount_test.go} | 71 +++++++++-------
14 files changed, 436 insertions(+), 93 deletions(-)
copy sdks/go/pkg/beam/io/filesystem/{local/local.go => memfs/memory.go} (50%)
create mode 100644 sdks/go/pkg/beam/io/filesystem/memfs/memory_test.go
copy sdks/go/pkg/beam/{log/standard.go => io/filesystem/util.go} (59%)
create mode 100644 sdks/go/pkg/beam/testing/passert/hash.go
create mode 100644 sdks/go/test/integration/driver.go
rename sdks/go/{examples/windowed_wordcount =>
test/integration}/wordcount/wordcount.go (73%)
copy sdks/go/{pkg/beam/transforms/filter/distinct_test.go =>
test/integration/wordcount/wordcount_test.go} (51%)
--
To stop receiving notification emails like this one, please contact
j...@apache.org.
