org.apache.beam.sdk.transforms.errorhandling

Interface BadRecordRouter

All Superinterfaces:

java.io.Serializable

All Known Implementing Classes:

BadRecordRouter.RecordingBadRecordRouter, BadRecordRouter.ThrowingBadRecordRouter

public interface BadRecordRouter
extends java.io.Serializable

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	BadRecordRouter.RecordingBadRecordRouter
static class	BadRecordRouter.ThrowingBadRecordRouter

Field Summary

Fields

Modifier and Type	Field and Description
static TupleTag<BadRecord>	BAD_RECORD_TAG
static BadRecordRouter	RECORDING_ROUTER
static BadRecordRouter	THROWING_ROUTER

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)

Field Detail

THROWING_ROUTER

static final BadRecordRouter THROWING_ROUTER

RECORDING_ROUTER

static final BadRecordRouter RECORDING_ROUTER

BAD_RECORD_TAG

static final TupleTag<BadRecord> BAD_RECORD_TAG

Method Detail

route

<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

Throws:

java.lang.Exception

route

<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

Throws:

java.lang.Exception