@DefaultAnnotation(value=org.checkerframework.checker.nullness.qual.NonNull.class)
See: Description
| Interface | Description |
|---|---|
| BadRecordRouter | |
| ErrorHandler<ErrorT,OutputT extends POutput> |
An Error Handler is a utility object used for plumbing error PCollections to a configured sink
Error Handlers must be closed before a pipeline is run to properly pipe error collections to the
sink, and the pipeline will be rejected if any handlers aren't closed.
|
| Class | Description |
|---|---|
| BadRecord | |
| BadRecord.Builder | |
| BadRecord.Failure | |
| BadRecord.Failure.Builder | |
| BadRecord.Record | |
| BadRecord.Record.Builder | |
| BadRecordRouter.RecordingBadRecordRouter | |
| BadRecordRouter.ThrowingBadRecordRouter | |
| ErrorHandler.BadRecordErrorHandler<OutputT extends POutput> | |
| ErrorHandler.DefaultErrorHandler<ErrorT,OutputT extends POutput> |
A default, placeholder error handler that exists to allow usage of .addErrorCollection()
without effects.
|
| ErrorHandler.PTransformErrorHandler<ErrorT,OutputT extends POutput> | |
| ErrorHandler.PTransformErrorHandler.WriteErrorMetrics<ErrorT> | |
| ErrorHandler.PTransformErrorHandler.WriteErrorMetrics.CountErrors<ErrorT> |