This is an automated email from the ASF dual-hosted git repository.
johncasey pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from fca93a5a480 Updated label_prs workflow (#173) (#23145)
add 6db3030481e [CdapIO] CdapIO and SparkReceiverIO updates (#24436)
No new revisions were added by this update.
Summary of changes:
sdks/java/io/cdap/build.gradle | 5 +-
.../java/org/apache/beam/sdk/io/cdap/CdapIO.java | 89 +++++++++++----
.../org/apache/beam/sdk/io/cdap/MappingUtils.java | 102 +----------------
.../java/org/apache/beam/sdk/io/cdap/Plugin.java | 127 +++++++++++++++++----
.../beam/sdk/io/cdap/context/BatchContextImpl.java | 51 ++++++++-
.../io/cdap/context/FailureCollectorWrapper.java | 18 +++
.../org/apache/beam/sdk/io/cdap/CdapIOTest.java | 36 ++++--
.../org/apache/beam/sdk/io/cdap/PluginTest.java | 12 +-
.../cdap/context/FailureCollectorWrapperTest.java | 24 ++++
.../ReadFromSparkReceiverWithOffsetDoFn.java | 37 +++++-
.../beam/sdk/io/sparkreceiver/SparkReceiverIO.java | 28 ++++-
.../sdk/io/sparkreceiver/SparkReceiverIOTest.java | 27 +++++
12 files changed, 393 insertions(+), 163 deletions(-)
