This is an automated email from the ASF dual-hosted git repository.
chamikara pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 1fa12d9 Merge pull request #16325 from [BEAM-13471] [Playground] Tag
existing unit-tests
add 08dd404 Adds several example multi-language Python pipelines
add b87d142 Merge pull request #16488: [BEAM-13637] Adds several example
multi-language Python pipelines
No new revisions were added by this update.
Summary of changes:
examples/multi-language/README.md | 41 ++++++++
.../multi-language}/build.gradle | 15 +--
examples/multi-language/python/addprefix.py | 98 +++++++++++++++++++
examples/multi-language/python/javacount.py | 104 +++++++++++++++++++++
.../multi-language/python/javadatagenerator.py | 89 ++++++++++++++++++
.../beam/examples/multilanguage/JavaCount.java | 17 ++--
.../examples/multilanguage/JavaCountBuilder.java | 20 ++--
.../multilanguage/JavaCountConfiguration.java | 4 +-
.../examples/multilanguage/JavaCountRegistrar.java | 14 +--
.../examples/multilanguage/JavaDataGenerator.java | 97 +++++++++++++++++++
.../beam/examples/multilanguage/JavaPrefix.java | 36 ++++---
.../examples/multilanguage/JavaPrefixBuilder.java | 19 ++--
.../multilanguage/JavaPrefixConfiguration.java | 18 +++-
.../multilanguage/JavaPrefixRegistrar.java | 14 +--
settings.gradle.kts | 1 +
15 files changed, 515 insertions(+), 72 deletions(-)
create mode 100644 examples/multi-language/README.md
copy {sdks/java/io/google-cloud-platform/expansion-service =>
examples/multi-language}/build.gradle (70%)
create mode 100644 examples/multi-language/python/addprefix.py
create mode 100644 examples/multi-language/python/javacount.py
create mode 100644 examples/multi-language/python/javadatagenerator.py
copy
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/ParseException.java
=>
examples/multi-language/src/main/java/org/apache/beam/examples/multilanguage/JavaCount.java
(67%)
copy
runners/twister2/src/main/java/org/apache/beam/runners/twister2/translators/streaming/ReadSourceTranslatorStream.java
=>
examples/multi-language/src/main/java/org/apache/beam/examples/multilanguage/JavaCountBuilder.java
(63%)
copy
runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/package-info.java
=>
examples/multi-language/src/main/java/org/apache/beam/examples/multilanguage/JavaCountConfiguration.java
(90%)
copy
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/internal/ExternalTransformRegistrarImpl.java
=>
examples/multi-language/src/main/java/org/apache/beam/examples/multilanguage/JavaCountRegistrar.java
(65%)
create mode 100644
examples/multi-language/src/main/java/org/apache/beam/examples/multilanguage/JavaDataGenerator.java
copy
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/internal/ProtoToBytes.java
=>
examples/multi-language/src/main/java/org/apache/beam/examples/multilanguage/JavaPrefix.java
(58%)
copy
runners/twister2/src/main/java/org/apache/beam/runners/twister2/translators/streaming/ReadSourceTranslatorStream.java
=>
examples/multi-language/src/main/java/org/apache/beam/examples/multilanguage/JavaPrefixBuilder.java
(63%)
copy
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/pubsub/package-info.java
=>
examples/multi-language/src/main/java/org/apache/beam/examples/multilanguage/JavaPrefixConfiguration.java
(77%)
copy
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/internal/ExternalTransformRegistrarImpl.java
=>
examples/multi-language/src/main/java/org/apache/beam/examples/multilanguage/JavaPrefixRegistrar.java
(65%)
