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:

java.io.Serializable, java.lang.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 java.lang.Object
implements ErrorHandler<ErrorT,OutputT>

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and 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 and 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 and Description
void	addErrorCollection(PCollection<ErrorT> errorCollection)
void	close()
OutputT	getOutput()
boolean	isClosed()

Methods inherited from class java.lang.Object

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

Constructor Detail

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 Detail

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 OutputT getOutput()

Specified by:

getOutput in interface ErrorHandler<ErrorT,OutputT extends POutput>

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable