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

Interface BadRecordRouter

All Superinterfaces:

Serializable

All Known Implementing Classes:

BadRecordRouter.RecordingBadRecordRouter, BadRecordRouter.ThrowingBadRecordRouter

public interface BadRecordRouter
extends Serializable

Nested Class Summary

Nested Classes

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

Field Summary

Fields

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

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)

Field Details

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 Details

route

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

Throws:

Exception

route

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

Throws:

Exception