org.apache.beam.sdk.transforms.errorhandling

Class BadRecord

java.lang.Object

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

All Implemented Interfaces:

java.io.Serializable

@DefaultSchema(value=AutoValueSchema.class)
public abstract class BadRecord
extends java.lang.Object
implements java.io.Serializable

See Also:

Serialized Form

Nested Class Summary

Nested Classes

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

Constructor Summary

Constructors

Constructor and Description
BadRecord()

Method Summary

Modifier and Type	Method and Description
static BadRecord.Builder	builder()
static <RecordT> BadRecord	fromExceptionInformation(RecordT record, @Nullable Coder<RecordT> coder, @Nullable java.lang.Exception exception, java.lang.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 Detail

BadRecord

public BadRecord()

Method Detail

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 java.lang.Exception exception,
                                                           java.lang.String description)
                                                    throws java.io.IOException

Throws:

java.io.IOException