org.apache.beam.sdk.transforms.errorhandling

Class BadRecordRouter.RecordingBadRecordRouter

java.lang.Object

org.apache.beam.sdk.transforms.errorhandling.BadRecordRouter.RecordingBadRecordRouter

All Implemented Interfaces:

java.io.Serializable, BadRecordRouter

Enclosing interface:

BadRecordRouter

public static class BadRecordRouter.RecordingBadRecordRouter
extends java.lang.Object
implements BadRecordRouter

See Also:

Serialized Form

Nested Class Summary

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

BadRecordRouter.RecordingBadRecordRouter, BadRecordRouter.ThrowingBadRecordRouter

Field Summary

Fields inherited from interface org.apache.beam.sdk.transforms.errorhandling.BadRecordRouter

BAD_RECORD_TAG, RECORDING_ROUTER, THROWING_ROUTER

Constructor Summary

Constructors

Constructor and Description
RecordingBadRecordRouter()

Method Summary

Modifier and Type	Method and Description
<RecordT> void	route(DoFn.MultiOutputReceiver outputReceiver, RecordT record, @Nullable Coder<RecordT> coder, @Nullable java.lang.Exception exception, java.lang.String description)
<RecordT> void	route(DoFn.FinishBundleContext c, RecordT record, @Nullable Coder<RecordT> coder, @Nullable java.lang.Exception exception, java.lang.String description, BoundedWindow window)

Methods inherited from class java.lang.Object

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

Constructor Detail

RecordingBadRecordRouter

public RecordingBadRecordRouter()

Method Detail

route

public <RecordT> void route(DoFn.MultiOutputReceiver outputReceiver,
                            RecordT record,
                            @Nullable Coder<RecordT> coder,
                            @Nullable java.lang.Exception exception,
                            java.lang.String description)
                     throws java.lang.Exception

Specified by:

route in interface BadRecordRouter

Throws:

java.lang.Exception

route

public <RecordT> void route(DoFn.FinishBundleContext c,
                            RecordT record,
                            @Nullable Coder<RecordT> coder,
                            @Nullable java.lang.Exception exception,
                            java.lang.String description,
                            BoundedWindow window)
                     throws java.lang.Exception

Specified by:

route in interface BadRecordRouter

Throws:

java.lang.Exception