You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by jo...@apache.org on 2023/06/20 17:03:10 UTC

[beam] branch master updated (4c66866aa95 -> 1c12f92a9a5)

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 4c66866aa95 Avro datum factory fixup (#27173)
     add 1c12f92a9a5 Add initial DLQ router (#27045)

No new revisions were added by this update.

Summary of changes:
 .../{contextualtextio => components}/build.gradle  |  8 +--
 .../io/components/deadletterqueue/DLQRouter.java   | 55 ++++++++++++++++
 .../deadletterqueue/sinks/ThrowingSink.java        | 26 ++++----
 .../components/deadletterqueue/DLQRouterTest.java  | 75 ++++++++++++++++++++++
 4 files changed, 147 insertions(+), 17 deletions(-)
 copy sdks/java/io/{contextualtextio => components}/build.gradle (89%)
 create mode 100644 sdks/java/io/components/src/main/java/org/apache/beam/sdk/io/components/deadletterqueue/DLQRouter.java
 copy examples/multi-language/src/main/java/org/apache/beam/examples/multilanguage/JavaPrefix.java => sdks/java/io/components/src/main/java/org/apache/beam/sdk/io/components/deadletterqueue/sinks/ThrowingSink.java (60%)
 create mode 100644 sdks/java/io/components/src/test/java/org/apache/beam/sdk/io/components/deadletterqueue/DLQRouterTest.java