You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ch...@apache.org on 2022/08/02 23:59:26 UTC
[beam] branch master updated (424e6a5c5da -> 74a534b3c0a)

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

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


    from 424e6a5c5da Add clearer error message for xlang transforms on teh Go Direct Runner (#22562)
     add 74a534b3c0a [CdapIO] Add integration tests for CdapIO (Batch) (#22313)

No new revisions were added by this update.

Summary of changes:
 ...t.groovy => job_PerformanceTests_CdapIO.groovy} |  13 +-
 sdks/java/io/cdap/build.gradle                     |   3 +
 .../org/apache/beam/sdk/io/cdap/CdapIOIT.java}     | 231 ++++++++++-----------
 .../{EmployeeBatchSink.java => DBBatchSink.java}   |  16 +-
 ...EmployeeBatchSource.java => DBBatchSource.java} |  22 +-
 .../java/org/apache/beam/sdk/io/cdap/DBConfig.java | 118 +++++++++++
 .../beam/sdk/io/cdap/DBInputFormatProvider.java    |  70 +++++++
 .../beam/sdk/io/cdap/DBOutputFormatProvider.java   |  68 ++++++
 .../beam/sdk/io/cdap}/TestRowDBWritable.java       |   2 +-
 9 files changed, 395 insertions(+), 148 deletions(-)
 copy .test-infra/jenkins/{job_PerformanceTests_HadoopFormat.groovy => job_PerformanceTests_CdapIO.groovy} (87%)
 copy sdks/java/io/{hadoop-format/src/test/java/org/apache/beam/sdk/io/hadoop/format/HadoopFormatIOIT.java => cdap/src/test/java/org/apache/beam/sdk/io/cdap/CdapIOIT.java} (67%)
 copy sdks/java/io/cdap/src/test/java/org/apache/beam/sdk/io/cdap/{EmployeeBatchSink.java => DBBatchSink.java} (81%)
 copy sdks/java/io/cdap/src/test/java/org/apache/beam/sdk/io/cdap/{EmployeeBatchSource.java => DBBatchSource.java} (82%)
 create mode 100644 sdks/java/io/cdap/src/test/java/org/apache/beam/sdk/io/cdap/DBConfig.java
 create mode 100644 sdks/java/io/cdap/src/test/java/org/apache/beam/sdk/io/cdap/DBInputFormatProvider.java
 create mode 100644 sdks/java/io/cdap/src/test/java/org/apache/beam/sdk/io/cdap/DBOutputFormatProvider.java
 copy sdks/java/io/{hadoop-format/src/test/java/org/apache/beam/sdk/io/hadoop/format => cdap/src/test/java/org/apache/beam/sdk/io/cdap}/TestRowDBWritable.java (98%)