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

@DefaultAnnotation(org.checkerframework.checker.nullness.qual.NonNull.class) package org.apache.beam.sdk.schemas.io

Provides abstractions for schema-aware IOs.

Related Packages

Package	Description
org.apache.beam.sdk.schemas	Defines Schema and other classes for representing schema'd data in a Pipeline.
org.apache.beam.sdk.schemas.io.payloads	Provides abstractions for schema-aware IOs.
org.apache.beam.sdk.schemas.annotations	Defines Schema and other classes for representing schema'd data in a Pipeline.
org.apache.beam.sdk.schemas.logicaltypes	A set of common LogicalTypes for use with schemas.
org.apache.beam.sdk.schemas.parser	Defines utilities for deailing with schemas.
org.apache.beam.sdk.schemas.transforms	Defines transforms that work on PCollections with schemas..
org.apache.beam.sdk.schemas.utils	Defines utilities for deailing with schemas.

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.
GenericDlqProvider	A Provider for generic DLQ transforms that handle deserialization failures.
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.
Providers	Helpers for implementing the "Provider" pattern.
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.