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

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

Provides abstractions for schema-aware IOs.

See: Description

Interface Summary

Interface	Description
GenericDlqProvider	A Provider for generic DLQ transforms that handle deserialization failures.
Providers.Identifyable
PushdownProjector<InputT extends PInput>	Factory for creating a PTransform that can execute a projection.
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.

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

Provides abstractions for schema-aware IOs.