You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by mw...@apache.org on 2020/09/02 08:39:12 UTC

[beam] branch master updated (ab597ff -> 0335ba5)

This is an automated email from the ASF dual-hosted git repository.

mwalenia pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


    from ab597ff  [BEAM-5122][BEAM-7582] Re-enable ignored tests in PubsubJsonIT (#12750)
     add 0335ba5  [BEAM-10137] Add KinesisIO for cross-language usage with python wrapper (#12297)

No new revisions were added by this update.

Summary of changes:
 .../expansion-service/build.gradle                 |  17 +-
 .../org/apache/beam/sdk/io/kinesis/KinesisIO.java  | 121 +++++---
 .../sdk/io/kinesis/KinesisTransformRegistrar.java  | 266 +++++++++++++++++
 .../io/external/xlang_kinesisio_it_test.py         | 320 ++++++++++++++++++++
 sdks/python/apache_beam/io/kinesis.py              | 328 +++++++++++++++++++++
 sdks/python/test-suites/portable/common.gradle     |   2 +
 settings.gradle                                    |   1 +
 7 files changed, 1002 insertions(+), 53 deletions(-)
 copy sdks/java/io/{snowflake => kinesis}/expansion-service/build.gradle (74%)
 create mode 100644 sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/KinesisTransformRegistrar.java
 create mode 100644 sdks/python/apache_beam/io/external/xlang_kinesisio_it_test.py
 create mode 100644 sdks/python/apache_beam/io/kinesis.py