You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ar...@apache.org on 2022/07/15 12:09:52 UTC

[beam] branch master updated (2b42751cb79 -> b0225ca084c)

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

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


    from 2b42751cb79 Merge pull request #22175: [BEAM-22089] Fix query retry in Java FirestoreIO
     add 87267d57245 [BEAM-14101] Add Spark Receiver IO package and ReceiverBuilder (squashed)
     add b0225ca084c Merge pull request #17111: [BEAM-14101] [CdapIO] Add ReceiverBuilder for SparkReceiverIO

No new revisions were added by this update.

Summary of changes:
 sdks/java/io/{cdap => sparkreceiver}/OWNERS        |  0
 sdks/java/io/{neo4j => sparkreceiver}/build.gradle | 31 ++++----
 .../beam/sdk/io/sparkreceiver/ReceiverBuilder.java | 91 ++++++++++++++++++++++
 .../sdk/io/sparkreceiver/WrappedSupervisor.java    | 89 +++++++++++++++++++++
 .../beam/sdk/io/sparkreceiver}/package-info.java   |  4 +-
 .../sdk/io/sparkreceiver/ReceiverBuilderTest.java  | 89 +++++++++++++++++++++
 settings.gradle.kts                                |  1 +
 7 files changed, 290 insertions(+), 15 deletions(-)
 copy sdks/java/io/{cdap => sparkreceiver}/OWNERS (100%)
 copy sdks/java/io/{neo4j => sparkreceiver}/build.gradle (58%)
 create mode 100644 sdks/java/io/sparkreceiver/src/main/java/org/apache/beam/sdk/io/sparkreceiver/ReceiverBuilder.java
 create mode 100644 sdks/java/io/sparkreceiver/src/main/java/org/apache/beam/sdk/io/sparkreceiver/WrappedSupervisor.java
 copy sdks/java/io/{amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis => sparkreceiver/src/main/java/org/apache/beam/sdk/io/sparkreceiver}/package-info.java (89%)
 create mode 100644 sdks/java/io/sparkreceiver/src/test/java/org/apache/beam/sdk/io/sparkreceiver/ReceiverBuilderTest.java