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 f68ae5ff467 [BEAM-14449] Support cluster provisioning when using Flink
on Dataproc (#17736)
add 2b026dff4e8 Adds Java cross-language transforms for invoking Python
Map and FlatMap
new 40f83407920 Merge pull request #17696: [BEAM-14483] Adds Java
cross-language transforms for invoking Python Map and FlatMap
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../beam/runners/core/construction/External.java | 23 +++----
.../extensions/python/PythonExternalTransform.java | 40 ++++++++++++-
.../python/transforms}/DataframeTransform.java | 2 +-
.../extensions/python/transforms/PythonMap.java | 70 ++++++++++++++++++++++
.../python/{ => transforms}/package-info.java | 2 +-
.../{ => transforms}/DataframeTransformTest.java | 3 +-
.../PythonMapTest.java} | 45 +++++++-------
7 files changed, 149 insertions(+), 36 deletions(-)
rename
sdks/java/extensions/python/src/{test/java/org/apache/beam/sdk/extensions/python/io
=>
main/java/org/apache/beam/sdk/extensions/python/transforms}/DataframeTransform.java
(98%)
create mode 100644
sdks/java/extensions/python/src/main/java/org/apache/beam/sdk/extensions/python/transforms/PythonMap.java
copy
sdks/java/extensions/python/src/main/java/org/apache/beam/sdk/extensions/python/{
=> transforms}/package-info.java (93%)
copy
sdks/java/extensions/python/src/test/java/org/apache/beam/sdk/extensions/python/{
=> transforms}/DataframeTransformTest.java (95%)
rename
sdks/java/extensions/python/src/test/java/org/apache/beam/sdk/extensions/python/{DataframeTransformTest.java
=> transforms/PythonMapTest.java} (54%)
