Package org.apache.beam.sdk.schemas

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

Defines Schema and other classes for representing schema'd data in a Pipeline.

For further details, see the documentation for each class in this package.

Related Packages

Package	Description
org.apache.beam.sdk	Provides a simple, powerful model for building both batch and streaming parallel data processing Pipelines.
org.apache.beam.sdk.schemas.annotations	Defines Schema and other classes for representing schema'd data in a Pipeline.
org.apache.beam.sdk.schemas.io	Provides abstractions for schema-aware IOs.
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
AutoValueSchema	A SchemaProvider for AutoValue classes.
AutoValueSchema.AbstractGetterTypeSupplier	FieldValueTypeSupplier that's based on AutoValue getters.
CachingFactory<CreatedT extends @NonNull Object>	A wrapper around a Factory that assumes the schema parameter never changes.
Factory<T>	A Factory interface for schema-related objects for a specific Java type.
FieldAccessDescriptor	Used inside of a DoFn to describe which fields in a schema type need to be accessed for processing.
FieldAccessDescriptor.FieldDescriptor	Description of a single field.
FieldAccessDescriptor.FieldDescriptor.Builder	Builder class.
FieldAccessDescriptor.FieldDescriptor.ListQualifier	Qualifier for a list selector.
FieldAccessDescriptor.FieldDescriptor.MapQualifier	Qualifier for a map selector.
FieldAccessDescriptor.FieldDescriptor.Qualifier	OneOf union for a collection selector.
FieldAccessDescriptor.FieldDescriptor.Qualifier.Kind	The kind of qualifier.
FieldTypeDescriptors	Utilities for converting between Schema field types and TypeDescriptors that define Java objects which can represent these field types.
FieldValueGetter<ObjectT extends @NonNull Object,ValueT>	For internal use only; no backwards-compatibility guarantees.
FieldValueHaver<ObjectT>	For internal use only; no backwards-compatibility guarantees.
FieldValueSetter<ObjectT,ValueT>	For internal use only; no backwards-compatibility guarantees.
FieldValueTypeInformation	Represents type information for a Java type that will be used to infer a Schema type.
FieldValueTypeInformation.Builder
GetterBasedSchemaProvider	Deprecated. new implementations should extend the GetterBasedSchemaProviderV2 class' methods which receive TypeDescriptors instead of ordinary Classes as arguments, which permits to support generic type signatures during schema inference
GetterBasedSchemaProviderV2	A newer version of GetterBasedSchemaProvider, which works with TypeDescriptors, and which by default delegates the old, Class based methods, to the new ones.
JavaBeanSchema	A SchemaProvider for Java Bean objects.
JavaBeanSchema.GetterTypeSupplier	FieldValueTypeSupplier that's based on getter methods.
JavaBeanSchema.SetterTypeSupplier	FieldValueTypeSupplier that's based on setter methods.
JavaFieldSchema	A SchemaProvider for Java POJO objects.
JavaFieldSchema.JavaFieldTypeSupplier	FieldValueTypeSupplier that's based on public fields.
NoSuchSchemaException	Indicates that we are missing a schema for a type.
ProjectionConsumer	A ProjectionConsumer is a Schema-aware operation (such as a DoFn or PTransform) that has a FieldAccessDescriptor describing which fields the operation accesses.
ProjectionProducer<T>	A factory for operations that execute a projection on a Schema-aware PCollection.
RowMessages
Schema	Schema describes the fields in Row.
Schema.Builder	Builder class for building Schema objects.
Schema.EquivalenceNullablePolicy	Control whether nullable is included in equivalence check.
Schema.Field	Field of a row.
Schema.Field.Builder	Builder for Schema.Field.
Schema.FieldType	A descriptor of a single field type.
Schema.LogicalType<InputT,BaseT>	A LogicalType allows users to define a custom schema type.
Schema.Options
Schema.Options.Builder
Schema.TypeName	An enumerated list of type constructors.
SchemaCoder<T>	SchemaCoder is used as the coder for types that have schemas registered.
SchemaProvider	Concrete implementations of this class allow creation of schema service objects that vend a Schema for a specific type.
SchemaProviderRegistrar	SchemaProvider creators have the ability to automatically have their schemaProvider registered with this SDK by creating a ServiceLoader entry and a concrete implementation of this interface.
SchemaRegistry	A SchemaRegistry allows registering Schemas for a given Java Class or a TypeDescriptor.
SchemaTranslation	Utility methods for translating schemas.
SchemaUserTypeCreator	A creator interface for user types that have schemas.
SchemaUtils	A set of utility functions for schemas.