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 5fffad6 [BEAM-12533] Add simple `__repr__` for `DeferredDataFrame`
and `DeferredSeries` (#15089)
add 7158943 [BEAM-12383] Go Kafka integration test and framework changes.
add b86fcf9 Merge pull request #15093: [BEAM-12383] Go Kafka integration
test and framework changes.
No new revisions were added by this update.
Summary of changes:
sdks/go/pkg/beam/testing/ptest/ptest.go | 28 +++-
sdks/go/test/build.gradle | 8 +-
sdks/go/test/integration/flags.go | 42 ++++++
sdks/go/test/integration/integration.go | 3 +-
sdks/go/test/integration/io/xlang/kafka/jar.go | 65 +++++++++
sdks/go/test/integration/io/xlang/kafka/kafka.go | 77 ++++++++++
.../test/integration/io/xlang/kafka/kafka_test.go | 72 ++++++++++
sdks/go/test/integration/xlang/xlang_test.go | 20 +--
sdks/go/test/run_validatesrunner_tests.sh | 156 +++++++++++++++------
9 files changed, 408 insertions(+), 63 deletions(-)
create mode 100644 sdks/go/test/integration/flags.go
create mode 100644 sdks/go/test/integration/io/xlang/kafka/jar.go
create mode 100644 sdks/go/test/integration/io/xlang/kafka/kafka.go
create mode 100644 sdks/go/test/integration/io/xlang/kafka/kafka_test.go
