@DefaultAnnotation(value=org.checkerframework.checker.nullness.qual.NonNull.class)
See: Description
Interface | Description |
---|---|
GenericDlqProvider |
A Provider for generic DLQ transforms that handle deserialization failures.
|
SchemaIO |
An abstraction to create schema capable and aware IOs.
|
SchemaIOProvider |
Provider to create
SchemaIO instances for use in Beam SQL and other SDKs. |
Class | Description |
---|---|
Failure |
A generic failure of an SQL transform.
|
Failure.Builder | |
GenericDlq |
Helper to generate a DLQ transform to write PCollection
|
Exception | Description |
---|---|
InvalidConfigurationException |
Exception thrown when the configuration for a
SchemaIO is invalid. |
InvalidLocationException |
Exception thrown when the configuration for a
SchemaIO is invalid. |
InvalidSchemaException |
Exception thrown when the schema for a
SchemaIO is invalid. |