From commits-return-96105-archive-asf-public=cust-asf.ponee.io@beam.apache.org Thu Oct 4 01:47:03 2018 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx-eu-01.ponee.io (Postfix) with SMTP id B2DC118065B for ; Thu, 4 Oct 2018 01:47:02 +0200 (CEST) Received: (qmail 26806 invoked by uid 500); 3 Oct 2018 23:47:01 -0000 Mailing-List: contact commits-help@beam.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@beam.apache.org Delivered-To: mailing list commits@beam.apache.org Received: (qmail 26797 invoked by uid 99); 3 Oct 2018 23:47:01 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd4-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 03 Oct 2018 23:47:01 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd4-us-west.apache.org (ASF Mail Server at spamd4-us-west.apache.org) with ESMTP id 73DBBC0368 for ; Wed, 3 Oct 2018 23:47:01 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -110.301 X-Spam-Level: X-Spam-Status: No, score=-110.301 tagged_above=-999 required=6.31 tests=[ENV_AND_HDR_SPF_MATCH=-0.5, RCVD_IN_DNSWL_MED=-2.3, SPF_PASS=-0.001, USER_IN_DEF_SPF_WL=-7.5, USER_IN_WHITELIST=-100] autolearn=disabled Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new, port 10024) with ESMTP id mhaEZtkk-ORS for ; Wed, 3 Oct 2018 23:47:01 +0000 (UTC) Received: from mailrelay1-us-west.apache.org (mailrelay1-us-west.apache.org [209.188.14.139]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTP id B8F1B5F3E2 for ; Wed, 3 Oct 2018 23:47:00 +0000 (UTC) Received: from jira-lw-us.apache.org (unknown [207.244.88.139]) by mailrelay1-us-west.apache.org (ASF Mail Server at mailrelay1-us-west.apache.org) with ESMTP id 41AE4E0101 for ; Wed, 3 Oct 2018 23:47:00 +0000 (UTC) Received: from jira-lw-us.apache.org (localhost [127.0.0.1]) by jira-lw-us.apache.org (ASF Mail Server at jira-lw-us.apache.org) with ESMTP id 09FE32553D for ; Wed, 3 Oct 2018 23:47:00 +0000 (UTC) Date: Wed, 3 Oct 2018 23:47:00 +0000 (UTC) From: "Jeff Klukas (JIRA)" To: commits@beam.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Created] (BEAM-5638) Add exception handling to single message transforms in Java SDK MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 Jeff Klukas created BEAM-5638: --------------------------------- Summary: Add exception handling to single message transforms in Java SDK Key: BEAM-5638 URL: https://issues.apache.org/jira/browse/BEAM-5638 Project: Beam Issue Type: Improvement Components: sdk-java-core Reporter: Jeff Klukas Assignee: Kenneth Knowles Add methods to MapElements, FlatMapElements, and Filter that allow users to specify expected exceptions and tuple tags to associate with the with collections of the successfully and unsuccessfully processed elements. See discussion on dev list: https://lists.apache.org/thread.html/936ed2a5f2c01be066fd903abf70130625e0b8cf4028c11b89b8b23f@%3Cdev.beam.apache.org%3E -- This message was sent by Atlassian JIRA (v7.6.3#76005)