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 java.lang.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 and Description
ExceptionElement()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

ExceptionElement

public ExceptionElement()

Method Detail

element

public abstract T element()

exception

public abstract java.lang.Exception exception()

of

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