@DefaultAnnotation(org.checkerframework.checker.nullness.qual.NonNull.class)

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

Provides abstractions for schema-aware IOs.

Interface Summary

Interface	Description
GenericDlqProvider	A Provider for generic DLQ transforms that handle deserialization failures.
Providers.Identifyable
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 Summary

Class	Description
DeadLetteredTransform<InputT,OutputT>
Failure	A generic failure of an SQL transform.
Failure.Builder
GenericDlq	Helper to generate a DLQ transform to write PCollection to an external system.
Providers	Helpers for implementing the "Provider" pattern.

Exception Summary

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.