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