Package org.apache.beam.sdk.schemas.io
Class GenericDlq
- java.lang.Object
-
- org.apache.beam.sdk.schemas.io.GenericDlq
-
@Internal @Experimental(SCHEMAS) public final class GenericDlq extends java.lang.Object
Helper to generate a DLQ transform to write PCollectionto an external system.
-
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static PTransform<PCollection<Failure>,PDone>
getDlqTransform(java.lang.String fullConfig)
-
-
-
Method Detail
-
getDlqTransform
public static PTransform<PCollection<Failure>,PDone> getDlqTransform(java.lang.String fullConfig)
-
-