Package org.apache.beam.sdk.io.csv

Class CsvIOParseError

java.lang.Object

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

@DefaultSchema(AutoValueSchema.class)
public abstract class CsvIOParseError
extends 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	Description
CsvIOParseError()

Method Summary

Modifier and Type	Method	Description
abstract @Nullable String	getCsvRecord()	The CSV record associated with the caught Exception.
abstract @Nullable String	getFilename()	The filename associated with the caught Exception.
abstract String	getMessage()	The caught Throwable.getMessage().
abstract Instant	getObservedTimestamp()	The date and time when the Exception occurred.
abstract 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 Details

CsvIOParseError

public CsvIOParseError()

Method Details

getMessage

public abstract String getMessage()

The caught Throwable.getMessage().

getCsvRecord

public abstract @Nullable 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 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 String getStackTrace()

The caught Throwable.getStackTrace().