org.apache.beam.sdk.schemas.io

Class Failure

java.lang.Object

org.apache.beam.sdk.schemas.io.Failure

@Internal
 @DefaultSchema(value=AutoValueSchema.class)
public abstract class Failure
extends java.lang.Object

A generic failure of an SQL transform.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Failure.Builder

Constructor Summary

Constructors

Constructor and Description
Failure()

Method Summary

Modifier and Type	Method and Description
abstract java.lang.String	getError() Information about the cause of the failure.
abstract byte[]	getPayload() Bytes containing the payload which has failed.
static Failure.Builder	newBuilder()

Methods inherited from class java.lang.Object

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

Constructor Detail

Failure

public Failure()

Method Detail

getPayload

public abstract byte[] getPayload()

Bytes containing the payload which has failed.

getError

public abstract java.lang.String getError()

Information about the cause of the failure.

newBuilder

public static Failure.Builder newBuilder()