This is an automated email from the ASF dual-hosted git repository.
yhu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from fcf111d299a Update documentation by adding parameters for Dataflow
Runner (#25561)
add 08198142087 [Playground] Apache Kafka based Kafka emulator for
Playground examples (#25357)
No new revisions were added by this update.
Summary of changes:
playground/backend/cmd/server/controller.go | 30 +++---
playground/backend/containers/go/Dockerfile | 7 ++
playground/backend/containers/go/build.gradle | 8 ++
playground/backend/containers/java/Dockerfile | 7 +-
playground/backend/containers/java/build.gradle | 9 ++
playground/backend/containers/python/Dockerfile | 7 ++
playground/backend/containers/python/build.gradle | 8 ++
playground/backend/containers/scio/Dockerfile | 6 ++
playground/backend/containers/scio/build.gradle | 8 ++
.../internal/code_processing/code_processing.go | 29 +++---
.../code_processing/code_processing_test.go | 8 +-
.../internal/db/mapper/datastore_mapper_test.go | 2 +-
.../db/schema/migration/migrations_test.go | 2 +-
playground/backend/internal/emulators/emulator.go | 51 +++++-----
playground/backend/internal/emulators/kafka.go | 109 +++++++++++++++++----
.../backend/internal/environment/application.go | 37 +++++--
.../internal/environment/environment_service.go | 91 +++++++++--------
.../environment/environment_service_test.go | 14 +--
playground/backend/internal/fs_tool/fs.go | 24 +++++
.../setup_tools/life_cycle/life_cycle_setuper.go | 44 ++++++---
.../life_cycle/life_cycle_setuper_test.go | 3 +-
.../kafka-emulator}/build.gradle | 41 +++++---
.../org/apache/beam/playground/KafkaEmulator.java | 72 ++++++++++++++
.../org/apache/beam/playground}/package-info.java | 6 +-
settings.gradle.kts | 1 +
25 files changed, 457 insertions(+), 167 deletions(-)
copy {model/pipeline => playground/kafka-emulator}/build.gradle (58%)
create mode 100644
playground/kafka-emulator/src/main/java/org/apache/beam/playground/KafkaEmulator.java
copy
{runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options
=>
playground/kafka-emulator/src/main/java/org/apache/beam/playground}/package-info.java
(80%)
