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

Class ErrorHandler.DefaultErrorHandler<ErrorT,OutputT extends POutput>

java.lang.Object

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

All Implemented Interfaces:

Serializable, AutoCloseable, ErrorHandler<ErrorT,OutputT>

Enclosing interface:

ErrorHandler<ErrorT,OutputT extends POutput>

@Internal
public static class ErrorHandler.DefaultErrorHandler<ErrorT,OutputT extends POutput>
extends Object
implements ErrorHandler<ErrorT,OutputT>

A default, placeholder error handler that exists to allow usage of .addErrorCollection() without effects. This enables more simple codepaths without checking for whether the user configured an error handler or not.

See Also:

• Serialized Form

Nested Class Summary

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
DefaultErrorHandler()

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

DefaultErrorHandler

public DefaultErrorHandler()

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