Package org.apache.beam.sdk.transforms.errorhandling

Class BadRecord.Failure

java.lang.Object

org.apache.beam.sdk.transforms.errorhandling.BadRecord.Failure

All Implemented Interfaces:

Serializable

Enclosing class:

BadRecord

@DefaultSchema(AutoValueSchema.class)
public abstract static class BadRecord.Failure
extends Object
implements Serializable

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	BadRecord.Failure.Builder

Constructor Summary

Constructors

Constructor	Description
Failure()

Method Summary

Modifier and Type	Method	Description
static BadRecord.Failure.Builder	builder()
abstract String	getDescription()	The description of what was being attempted when the failure occurred.
abstract @Nullable String	getException()	The exception itself, e.g.
abstract @Nullable String	getExceptionStacktrace()	The full stacktrace.

Methods inherited from class java.lang.Object

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

Constructor Details

Failure

public Failure()

Method Details

getException

public abstract @Nullable String getException()

The exception itself, e.g. IOException. Null if there is a failure without an exception.

getExceptionStacktrace

public abstract @Nullable String getExceptionStacktrace()

The full stacktrace. Null if there is a failure without an exception.

getDescription

public abstract String getDescription()

The description of what was being attempted when the failure occurred.

builder

public static BadRecord.Failure.Builder builder()