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/11/07 14:29:11 UTC
[beam] 01/01: Merge pull request #23962: [CdapIO] Add sparkreceiver:2 module.
This is an automated email from the ASF dual-hosted git repository.
aromanenko pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 0476d6498217b7b0e833643c47fef2c4bdaec529
Merge: 1d5fc14031d 6ae37b6f82a
Author: Alexey Romanenko <33...@users.noreply.github.com>
AuthorDate: Mon Nov 7 15:28:59 2022 +0100
Merge pull request #23962: [CdapIO] Add sparkreceiver:2 module.
.test-infra/jenkins/job_PerformanceTests_SparkReceiverIO_IT.groovy | 2 +-
sdks/java/io/cdap/build.gradle | 2 +-
sdks/java/io/sparkreceiver/{ => 2}/OWNERS | 0
sdks/java/io/sparkreceiver/{ => 2}/README.md | 0
sdks/java/io/sparkreceiver/{ => 2}/build.gradle | 0
.../src/main/java/org/apache/beam/sdk/io/sparkreceiver/HasOffset.java | 0
.../beam/sdk/io/sparkreceiver/ReadFromSparkReceiverWithOffsetDoFn.java | 0
.../java/org/apache/beam/sdk/io/sparkreceiver/ReceiverBuilder.java | 0
.../main/java/org/apache/beam/sdk/io/sparkreceiver/SparkConsumer.java | 0
.../java/org/apache/beam/sdk/io/sparkreceiver/SparkReceiverIO.java | 0
.../java/org/apache/beam/sdk/io/sparkreceiver/WrappedSupervisor.java | 0
.../main/java/org/apache/beam/sdk/io/sparkreceiver/package-info.java | 0
.../org/apache/beam/sdk/io/sparkreceiver/ArrayBufferDataReceiver.java | 0
.../org/apache/beam/sdk/io/sparkreceiver/ByteBufferDataReceiver.java | 0
.../org/apache/beam/sdk/io/sparkreceiver/CustomReceiverWithOffset.java | 0
.../org/apache/beam/sdk/io/sparkreceiver/IteratorDataReceiver.java | 0
.../apache/beam/sdk/io/sparkreceiver/RabbitMqReceiverWithOffset.java | 0
.../sdk/io/sparkreceiver/ReadFromSparkReceiverWithOffsetDoFnTest.java | 0
.../java/org/apache/beam/sdk/io/sparkreceiver/ReceiverBuilderTest.java | 0
.../java/org/apache/beam/sdk/io/sparkreceiver/SparkReceiverIOIT.java | 0
.../java/org/apache/beam/sdk/io/sparkreceiver/SparkReceiverIOTest.java | 0
settings.gradle.kts | 3 +--
22 files changed, 3 insertions(+), 4 deletions(-)