This is an automated email from the ASF dual-hosted git repository.
ibzib pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 9e07ab0 Merge pull request #16376 from ibzib/BEAM-13572
add 8b50ba2 [BEAM-13052] Add Pub/Sub Lite xlang transforms in python
(#15727)
No new revisions were added by this update.
Summary of changes:
.../internal/ExternalTransformConfig.java | 108 ++++++++++++++++++
.../internal/ExternalTransformRegistrarImpl.java} | 21 ++--
.../gcp/pubsublite/internal/ProtoFromBytes.java} | 45 ++++----
.../io/gcp/pubsublite/internal/ProtoToBytes.java | 33 +++---
.../{tools => io/gcp/pubsublite}/__init__.py | 8 +-
.../apache_beam/io/gcp/pubsublite/external.py | 126 +++++++++++++++++++++
.../apache_beam/io/gcp/pubsublite/proto_api.py | 112 ++++++++++++++++++
sdks/python/setup.py | 1 +
8 files changed, 400 insertions(+), 54 deletions(-)
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/internal/ExternalTransformConfig.java
copy
sdks/java/io/{snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/crosslanguage/SnowflakeTransformRegistrar.java
=>
google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/internal/ExternalTransformRegistrarImpl.java}
(70%)
copy
sdks/java/{testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/RowToCsv.java
=>
io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/internal/ProtoFromBytes.java}
(51%)
copy learning/katas/java/Triggers/Early Triggers/Early
Triggers/src/org/apache/beam/learning/katas/triggers/earlytriggers/GenerateEvent.java
=>
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/internal/ProtoToBytes.java
(60%)
copy sdks/python/apache_beam/{tools => io/gcp/pubsublite}/__init__.py (86%)
create mode 100644 sdks/python/apache_beam/io/gcp/pubsublite/external.py
create mode 100644 sdks/python/apache_beam/io/gcp/pubsublite/proto_api.py
