Class BadRecord
java.lang.Object
org.apache.beam.sdk.transforms.errorhandling.BadRecord
- All Implemented Interfaces:
Serializable
@DefaultSchema(AutoValueSchema.class)
public abstract class BadRecord
extends Object
implements Serializable
- See Also:
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic class
static class
static class
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic BadRecord.Builder
builder()
static <RecordT> BadRecord
fromExceptionInformation
(RecordT record, @Nullable Coder<RecordT> coder, @Nullable Exception exception, String description) abstract BadRecord.Failure
Information about why the record failed.abstract BadRecord.Record
Information about the record that failed.
-
Constructor Details
-
BadRecord
public BadRecord()
-
-
Method Details
-
getRecord
Information about the record that failed. -
getFailure
Information about why the record failed. -
builder
-
getCoder
-
fromExceptionInformation
public static <RecordT> BadRecord fromExceptionInformation(RecordT record, @Nullable Coder<RecordT> coder, @Nullable Exception exception, String description) throws IOException - Throws:
IOException
-