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 71706b280ee Automatically clean up old metrics containers (#27811)
add 4eed089e180 Implement go xlang wrapper for reading from Bigtable
(#27778)
No new revisions were added by this update.
Summary of changes:
sdks/go/pkg/beam/core/runtime/xlangx/payload.go | 28 +++-
sdks/go/pkg/beam/io/xlang/bigtableio/bigtable.go | 137 ++++++++++++++++
.../beam/transforms/xlang/inference/inference.go | 2 +-
.../pkg/beam/transforms/xlang/schema/external.go | 94 +++++++++++
sdks/go/test/build.gradle | 1 +
sdks/go/test/integration/flags.go | 5 +
sdks/go/test/integration/integration.go | 5 +
.../test/integration/io/xlang/bigtable/bigtable.go | 6 +-
.../integration/io/xlang/bigtable/bigtable_test.go | 179 +++++++++++++++++++++
9 files changed, 444 insertions(+), 13 deletions(-)
create mode 100644 sdks/go/pkg/beam/io/xlang/bigtableio/bigtable.go
create mode 100644 sdks/go/pkg/beam/transforms/xlang/schema/external.go
copy
playground/frontend/playground_components/test/tools/extract_symbols_go/sdk_mock/directory/file2.go
=> sdks/go/test/integration/io/xlang/bigtable/bigtable.go (88%)
create mode 100644 sdks/go/test/integration/io/xlang/bigtable/bigtable_test.go
