org.apache.beam.sdk.io.csv

Class CsvIOParseError

java.lang.Object

org.apache.beam.sdk.io.csv.CsvIOParseError

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

CsvIOParseError is a data class to store errors from CSV record processing. It is Schema mapped for compatibility with writing to Beam Schema-aware I/O connectors.

Constructor Summary

Constructors

Constructor and Description
CsvIOParseError()

Method Summary

Modifier and Type	Method and Description
abstract @Nullable java.lang.String	getCsvRecord() The CSV record associated with the caught Exception.
abstract @Nullable java.lang.String	getFilename() The filename associated with the caught Exception.
abstract java.lang.String	getMessage() The caught Throwable.getMessage().
abstract Instant	getObservedTimestamp() The date and time when the Exception occurred.
abstract java.lang.String	getStackTrace() The caught Throwable.getStackTrace().

Methods inherited from class java.lang.Object

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

Constructor Detail

CsvIOParseError

public CsvIOParseError()

Method Detail

getMessage

public abstract java.lang.String getMessage()

The caught Throwable.getMessage().

getCsvRecord

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

The CSV record associated with the caught Exception. Annotated Nullable as not all processing errors are associated with a CSV record.

getFilename

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

The filename associated with the caught Exception. Annotated Nullable as not all processing errors are associated with a file.

getObservedTimestamp

public abstract Instant getObservedTimestamp()

The date and time when the Exception occurred.

getStackTrace

public abstract java.lang.String getStackTrace()

The caught Throwable.getStackTrace().