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/07/17 03:39:22 UTC
[beam] 01/01: Merge pull request #12215: [BEAM-10310] Adding
thread-safe restriction tracker wrapper.
This is an automated email from the ASF dual-hosted git repository.
danoliveira pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 535c0f655676726fd4d8fed6eac57c792c58f208
Merge: e34fef8 04e5cd3
Author: Daniel Oliveira <da...@gmail.com>
AuthorDate: Thu Jul 16 20:39:02 2020 -0700
Merge pull request #12215: [BEAM-10310] Adding thread-safe restriction tracker wrapper.
sdks/go/examples/stringsplit/stringsplit.go | 15 ++--
sdks/go/pkg/beam/core/graph/fn_test.go | 3 +
.../beam/core/runtime/exec/sdf_invokers_test.go | 3 +-
.../pkg/beam/core/runtime/graphx/translate_test.go | 15 ++--
sdks/go/pkg/beam/core/sdf/lock.go | 82 ++++++++++++++++++++++
sdks/go/pkg/beam/core/sdf/sdf.go | 4 ++
.../beam/io/rtrackers/offsetrange/offsetrange.go | 67 ++++++++++--------
sdks/go/pkg/beam/io/synthetic/source.go | 11 +--
sdks/go/pkg/beam/io/synthetic/step.go | 15 ++--
9 files changed, 157 insertions(+), 58 deletions(-)