org.apache.beam.sdk.transforms.errorhandling

Class BadRecordRouter.ThrowingBadRecordRouter

java.lang.Object

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

All Implemented Interfaces:

java.io.Serializable, BadRecordRouter

Enclosing interface:

BadRecordRouter

public static class BadRecordRouter.ThrowingBadRecordRouter
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
ThrowingBadRecordRouter()

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

ThrowingBadRecordRouter

public ThrowingBadRecordRouter()

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