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

Interface GenericDlqProvider

All Superinterfaces:

Providers.Identifyable

@Internal
@Experimental(SCHEMAS)
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(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.