Package org.apache.beam.sdk.transforms

Class WithFailures.ExceptionElement<T>

java.lang.Object

org.apache.beam.sdk.transforms.WithFailures.ExceptionElement<T>

Enclosing class:

WithFailures

public abstract static class WithFailures.ExceptionElement<T>
extends Object

The value type passed as input to exception handlers. It wraps an exception together with the input element that was being processed at the time the exception was raised.

Exception handlers may want to re-raise the exception and catch only specific subclasses in order to limit the scope of handled exceptions or access subclass-specific data.

Constructor Summary

Constructors

Constructor	Description
ExceptionElement()

Method Summary

Modifier and Type	Method	Description
abstract T	element()
abstract Exception	exception()
static <T> WithFailures.ExceptionElement<T>	of(T element, Exception exception)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ExceptionElement

public ExceptionElement()

Method Details

element

public abstract T element()

exception

public abstract Exception exception()

of

public static <T> WithFailures.ExceptionElement<T> of(T element,
 Exception exception)