Package org.apache.beam.sdk.transforms.errorhandling
package org.apache.beam.sdk.transforms.errorhandling
Provides utilities for handling errors in Pipelines.
-
ClassDescriptionErrorHandler<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.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>