org.apache.beam.sdk.schemas.transforms.providers

Class ErrorHandling

java.lang.Object

org.apache.beam.sdk.schemas.transforms.providers.ErrorHandling

All Implemented Interfaces:

java.io.Serializable

public abstract class ErrorHandling
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	ErrorHandling.Builder

Constructor Summary

Constructors

Constructor and Description
ErrorHandling()

Method Summary

Modifier and Type	Method and Description
static ErrorHandling.Builder	builder()
static Row	errorRecord(Schema errorSchema, byte[] inputBytes, java.lang.Throwable th)
static Row	errorRecord(Schema errorSchema, Row inputRow, java.lang.Throwable th)
static Schema	errorSchema(Schema inputSchema)
static Schema	errorSchemaBytes()
abstract java.lang.String	getOutput()
static java.lang.String	getOutputOrNull(ErrorHandling errorHandling)
static boolean	hasOutput(ErrorHandling errorHandling)

Methods inherited from class java.lang.Object

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

Constructor Detail

ErrorHandling

public ErrorHandling()

Method Detail

getOutput

@SchemaFieldDescription(value="The name of the output PCollection containing failed writes.")
public abstract java.lang.String getOutput()

builder

public static ErrorHandling.Builder builder()

hasOutput

public static boolean hasOutput(@Nullable
                                ErrorHandling errorHandling)

getOutputOrNull

@Nullable
public static java.lang.String getOutputOrNull(@Nullable
                                                         ErrorHandling errorHandling)

errorSchema

public static Schema errorSchema(Schema inputSchema)

errorSchemaBytes

public static Schema errorSchemaBytes()

errorRecord

public static Row errorRecord(Schema errorSchema,
                              Row inputRow,
                              java.lang.Throwable th)

errorRecord

public static Row errorRecord(Schema errorSchema,
                              byte[] inputBytes,
                              java.lang.Throwable th)