Package org.apache.beam.sdk.io.gcp.bigquery

Class BigQueryDlqProvider

java.lang.Object

org.apache.beam.sdk.io.gcp.bigquery.BigQueryDlqProvider

All Implemented Interfaces:

GenericDlqProvider, Providers.Identifyable

@Internal
@AutoService(GenericDlqProvider.class)
public class BigQueryDlqProvider
extends Object
implements GenericDlqProvider

Constructor Summary

Constructors

Constructor	Description
BigQueryDlqProvider()

Method Summary

Modifier and Type	Method	Description
String	identifier()	Returns an id that uniquely represents this among others implementing its derived interface.
PTransform<PCollection<Failure>,PDone>	newDlqTransform(String config)	Generate a DLQ output from the provided config value.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

BigQueryDlqProvider

public BigQueryDlqProvider()

Method Details

identifier

public String identifier()

Description copied from interface: Providers.Identifyable

Returns an id that uniquely represents this among others implementing its derived interface.

Specified by:

identifier in interface Providers.Identifyable

newDlqTransform

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

Description copied from interface: GenericDlqProvider

Generate a DLQ output from the provided config value.

Specified by:

newDlqTransform in interface GenericDlqProvider