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

Class ErrorHandler.PTransformErrorHandler<ErrorT,OutputT extends POutput>

java.lang.Object

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

All Implemented Interfaces:

Serializable, AutoCloseable, ErrorHandler<ErrorT,OutputT>

Direct Known Subclasses:

ErrorHandler.BadRecordErrorHandler

Enclosing interface:

ErrorHandler<ErrorT,OutputT extends POutput>

public static class ErrorHandler.PTransformErrorHandler<ErrorT,OutputT extends POutput>
extends Object
implements ErrorHandler<ErrorT,OutputT>

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	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
PTransformErrorHandler(PTransform<PCollection<ErrorT>,OutputT> sinkTransform, Pipeline pipeline, Coder<ErrorT> coder)	Constructs a new ErrorHandler, but should not be called directly.

Method Summary

Modifier and Type	Method	Description
void	addErrorCollection(PCollection<ErrorT> errorCollection)
void	close()
@Nullable OutputT	getOutput()
boolean	isClosed()

Methods inherited from class java.lang.Object

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

Constructor Details

PTransformErrorHandler

@Internal
public PTransformErrorHandler(PTransform<PCollection<ErrorT>,OutputT> sinkTransform,
 Pipeline pipeline,
 Coder<ErrorT> coder)

Constructs a new ErrorHandler, but should not be called directly. Instead, call pipeline.registerErrorHandler to ensure safe pipeline construction

Method Details

addErrorCollection

public void addErrorCollection(PCollection<ErrorT> errorCollection)

Specified by:

addErrorCollection in interface ErrorHandler<ErrorT,OutputT extends POutput>

isClosed

public boolean isClosed()

Specified by:

isClosed in interface ErrorHandler<ErrorT,OutputT extends POutput>

getOutput

public @Nullable OutputT getOutput()

Specified by:

getOutput in interface ErrorHandler<ErrorT,OutputT extends POutput>

close

public void close()

Specified by:

close in interface AutoCloseable