You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by da...@apache.org on 2020/05/15 21:40:14 UTC
[beam] branch master updated (578694b -> 10b0f88)
This is an automated email from the ASF dual-hosted git repository.
danoliveira pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 578694b Merge pull request #11634 from Change TestStreamImpl to a producer/consumer pattern
add 176e1f0 [BEAM-9951] Creating a synthetic source for the Go SDK.
add 10b0f88 Merge pull request #11665: [BEAM-9951] Creating a synthetic source for the Go SDK.
No new revisions were added by this update.
Summary of changes:
sdks/go/examples/stringsplit/stringsplit.go | 8 +-
.../beam/io/rtrackers}/offsetrange/offsetrange.go | 5 +
sdks/go/pkg/beam/io/synthetic/source.go | 162 +++++++++++++++++++++
sdks/go/pkg/beam/io/synthetic/source_test.go | 138 ++++++++++++++++++
4 files changed, 309 insertions(+), 4 deletions(-)
rename sdks/go/{examples/stringsplit => pkg/beam/io/rtrackers}/offsetrange/offsetrange.go (93%)
create mode 100644 sdks/go/pkg/beam/io/synthetic/source.go
create mode 100644 sdks/go/pkg/beam/io/synthetic/source_test.go