You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lo...@apache.org on 2023/02/20 00:34:00 UTC
[beam] branch master updated (d652d054ecd -> ca1ec257c4a)
This is an automated email from the ASF dual-hosted git repository.
lostluck pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from d652d054ecd [Go SDK]: Retrieve file size in CreateInitialRestriction in textio.Read (#25535)
add ca1ec257c4a [#24789][prism] internal/worker + tentative data (#25478)
No new revisions were added by this update.
Summary of changes:
.../pkg/beam/runners/prism/internal/engine/data.go | 23 +-
.../beam/runners/prism/internal/worker/bundle.go | 114 ++++++
.../runners/prism/internal/worker/bundle_test.go | 52 +++
.../beam/runners/prism/internal/worker/worker.go | 421 +++++++++++++++++++++
.../runners/prism/internal/worker/worker_test.go | 281 ++++++++++++++
5 files changed, 878 insertions(+), 13 deletions(-)
copy learning/katas/go/core_transforms/map/pardo_onetomany/pkg/task/task.go => sdks/go/pkg/beam/runners/prism/internal/engine/data.go (67%)
create mode 100644 sdks/go/pkg/beam/runners/prism/internal/worker/bundle.go
create mode 100644 sdks/go/pkg/beam/runners/prism/internal/worker/bundle_test.go
create mode 100644 sdks/go/pkg/beam/runners/prism/internal/worker/worker.go
create mode 100644 sdks/go/pkg/beam/runners/prism/internal/worker/worker_test.go