org.apache.beam.sdk.transforms.errorhandling

Class BadRecord.Record

java.lang.Object

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

All Implemented Interfaces:

java.io.Serializable

Enclosing class:

BadRecord

@DefaultSchema(value=AutoValueSchema.class)
public abstract static class BadRecord.Record
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.Record.Builder

Constructor Summary

Constructors

Constructor and Description
Record()

Method Summary

Modifier and Type	Method and Description
static BadRecord.Record.Builder	builder()
abstract @Nullable java.lang.String	getCoder() The coder for the record, or null if there is no coder.
abstract byte[]	getEncodedRecord() Nullable to account for failing to encode, or if there is no coder for the record at the time of failure.
abstract @Nullable java.lang.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 Detail

Record

public Record()

Method Detail

getHumanReadableJsonRecord

public abstract @Nullable java.lang.String getHumanReadableJsonRecord()

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

getEncodedRecord

public abstract byte[] 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 java.lang.String getCoder()

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

builder

public static BadRecord.Record.Builder builder()