org.apache.beam.sdk.schemas.io

Interface GenericDlqProvider

All Known Implementing Classes:

BigQueryDlqProvider, DlqProvider, PubsubDlqProvider

@Internal
 @Experimental(value=SCHEMAS)
public interface GenericDlqProvider

A Provider for generic DLQ transforms that handle deserialization failures.

Method Summary

Modifier and Type	Method and Description
java.lang.String	identifier() Returns an id that uniquely represents this Dlq Provider.
PTransform<PCollection<Failure>,PDone>	newDlqTransform(java.lang.String config) Generate a DLQ output from the provided config value.

Method Detail

identifier

java.lang.String identifier()

Returns an id that uniquely represents this Dlq Provider.

newDlqTransform

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

Generate a DLQ output from the provided config value.