org.apache.beam.sdk.schemas.io

Interface GenericDlqProvider

All Superinterfaces:

Providers.Identifyable

All Known Implementing Classes:

BigQueryDlqProvider, DlqProvider, PubsubDlqProvider

@Internal
 @Experimental(value=SCHEMAS)
public interface GenericDlqProvider
extends Providers.Identifyable

A Provider for generic DLQ transforms that handle deserialization failures.

Method Summary

Modifier and Type	Method and Description
PTransform<PCollection<Failure>,PDone>	newDlqTransform(java.lang.String config) Generate a DLQ output from the provided config value.

Methods inherited from interface org.apache.beam.sdk.schemas.io.Providers.Identifyable

identifier

Method Detail

newDlqTransform

PTransform<PCollection<Failure>,PDone> newDlqTransform(java.lang.String config)

Generate a DLQ output from the provided config value.