[BEAM-5638] Add exception handling to single message transforms in Java SDK

• Type: Improvement
• Status: Resolved
• Priority: P3
• Resolution: Fixed
• Fix Version/s: 2.12.0
• Component/s: sdk-java-core
• Labels: Done
• Assignee: Jeff Klukas
• Reporter: Jeff Klukas
• Created: 03/Oct/18 23:46
• Updated: 06/Oct/20 21:50
• Resolved: 27/Aug/19 12:51

Description

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

Issue Links

• links to: GitHub Pull Request #6586
• links to: GitHub Pull Request #7736