Package org.apache.beam.sdk.schemas.io

Interface GenericDlqProvider

All Superinterfaces:

Providers.Identifyable

All Known Implementing Classes:

BigQueryDlqProvider, DlqProvider, PubsubDlqProvider

@Internal
public interface GenericDlqProvider
extends Providers.Identifyable

A Provider for generic DLQ transforms that handle deserialization failures.

Method Summary

Modifier and Type	Method	Description
PTransform<PCollection<Failure>,PDone>	newDlqTransform(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 Details

newDlqTransform

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

Generate a DLQ output from the provided config value.