Package org.apache.beam.sdk.transforms.errorhandling

Class ErrorHandler.BadRecordErrorHandler<OutputT extends POutput>

java.lang.Object

org.apache.beam.sdk.transforms.errorhandling.ErrorHandler.PTransformErrorHandler<BadRecord,OutputT>

org.apache.beam.sdk.transforms.errorhandling.ErrorHandler.BadRecordErrorHandler<OutputT>

All Implemented Interfaces:

Serializable, AutoCloseable, ErrorHandler<BadRecord,OutputT>

Enclosing interface:

ErrorHandler<ErrorT,OutputT extends POutput>

public static class ErrorHandler.BadRecordErrorHandler<OutputT extends POutput>
extends ErrorHandler.PTransformErrorHandler<BadRecord,OutputT>

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.beam.sdk.transforms.errorhandling.ErrorHandler.PTransformErrorHandler

ErrorHandler.PTransformErrorHandler.WriteErrorMetrics<ErrorT>

Nested classes/interfaces inherited from interface org.apache.beam.sdk.transforms.errorhandling.ErrorHandler

ErrorHandler.BadRecordErrorHandler<OutputT extends POutput>, ErrorHandler.DefaultErrorHandler<ErrorT,OutputT extends POutput>, ErrorHandler.PTransformErrorHandler<ErrorT,OutputT extends POutput>

Constructor Summary

Constructors

Constructor	Description
BadRecordErrorHandler(PTransform<PCollection<BadRecord>,OutputT> sinkTransform, Pipeline pipeline)	Constructs a new ErrorHandler for handling BadRecords.

Method Summary

Methods inherited from class org.apache.beam.sdk.transforms.errorhandling.ErrorHandler.PTransformErrorHandler

addErrorCollection, close, getOutput, isClosed

Methods inherited from class java.lang.Object

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

Constructor Details

BadRecordErrorHandler

@Internal
public BadRecordErrorHandler(PTransform<PCollection<BadRecord>,OutputT> sinkTransform,
 Pipeline pipeline)

Constructs a new ErrorHandler for handling BadRecords.