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:

java.io.Serializable, java.lang.AutoCloseable, ErrorHandler<ErrorT,OutputT>

Enclosing interface:

ErrorHandler<ErrorT,OutputT extends POutput>

@Internal
public static class ErrorHandler.DefaultErrorHandler<ErrorT,OutputT extends POutput>
extends java.lang.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 and Description
DefaultErrorHandler()

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

DefaultErrorHandler

public DefaultErrorHandler()

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