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

Class BadRecordRouter.RecordingBadRecordRouter

java.lang.Object

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

All Implemented Interfaces:

Serializable, BadRecordRouter

Enclosing interface:

BadRecordRouter

public static class BadRecordRouter.RecordingBadRecordRouter
extends 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	Description
RecordingBadRecordRouter()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Details

RecordingBadRecordRouter

public RecordingBadRecordRouter()

Method Details

route

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

Specified by:

route in interface BadRecordRouter

Throws:

Exception

route

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

Specified by:

route in interface BadRecordRouter

Throws:

Exception