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

Class BadRecord.Record

java.lang.Object

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

All Implemented Interfaces:

Serializable

Enclosing class:

BadRecord

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

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

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

Constructor Summary

Constructors

Constructor	Description
Record()

Method Summary

Modifier and Type	Method	Description
static BadRecord.Record.Builder	builder()
abstract @Nullable String	getCoder()	The coder for the record, or null if there is no coder.
abstract byte @Nullable []	getEncodedRecord()	Nullable to account for failing to encode, or if there is no coder for the record at the time of failure.
abstract @Nullable String	getHumanReadableJsonRecord()	The failing record, encoded as JSON.

Methods inherited from class java.lang.Object

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

Constructor Details

Record

public Record()

Method Details

getHumanReadableJsonRecord

public abstract @Nullable String getHumanReadableJsonRecord()

The failing record, encoded as JSON. Will be null if serialization as JSON fails.

getEncodedRecord

public abstract byte @Nullable [] getEncodedRecord()

Nullable to account for failing to encode, or if there is no coder for the record at the time of failure.

getCoder

public abstract @Nullable String getCoder()

The coder for the record, or null if there is no coder.

builder

public static BadRecord.Record.Builder builder()