beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From danolive...@apache.org
Subject [beam] 01/01: Merge pull request #12215: [BEAM-10310] Adding thread-safe restriction tracker wrapper.
Date Fri, 17 Jul 2020 03:39:22 GMT
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 <daniel.o.programmer@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(-)


Mime
View raw message