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

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:

• Serialized Form

Nested Class Summary

Nested Classes

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

Constructor Summary

Constructors

Constructor	Description
BadRecord()

Method Summary

Modifier and Type	Method	Description
static BadRecord.Builder	builder()
static <RecordT> BadRecord	fromExceptionInformation(RecordT record, @Nullable Coder<RecordT> coder, @Nullable Exception exception, String description)
static Coder<BadRecord>	getCoder(Pipeline pipeline)
abstract BadRecord.Failure	getFailure()	Information about why the record failed.
abstract BadRecord.Record	getRecord()	Information about the record that failed.

Methods inherited from class java.lang.Object

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

Constructor Details

BadRecord

public BadRecord()

Method Details

getRecord

public abstract BadRecord.Record getRecord()

Information about the record that failed.

getFailure

public abstract BadRecord.Failure getFailure()

Information about why the record failed.

builder

public static BadRecord.Builder builder()

getCoder

public static Coder<BadRecord> getCoder(Pipeline pipeline)

fromExceptionInformation

public static <RecordT> BadRecord fromExceptionInformation(RecordT record,
 @Nullable Coder<RecordT> coder,
 @Nullable Exception exception,
 String description)
                                                    throws IOException

Throws:

IOException