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

Package org.apache.beam.sdk.schemas.transforms

Defines transforms that work on PCollections with schemas..

See: Description

Interface Summary

Interface	Description
Cast.Validator	Interface for statically validating casts.
SchemaTransformProvider	Provider to create SchemaTransform instances for use in Beam SQL and other SDKs.

Class Summary

Class	Description
AddFields	A transform to add new nullable fields to a PCollection's schema.
AddFields.Inner<T>	Inner PTransform for AddFields.
Cast<T>	Set of utilities for casting rows between schemas.
Cast.CompatibilityError	Describes compatibility errors during casting.
Cast.Narrowing	Narrowing changes type without guarantee to preserve data.
Cast.Widening	Widening changes to type that can represent any possible value of the original type.
CoGroup	A transform that performs equijoins across multiple schema PCollections.
CoGroup.By	Defines the set of fields to extract for the join key, as well as other per-input join options.
CoGroup.ExpandCrossProduct	A PTransform that calculates the cross-product join.
CoGroup.Impl	The implementing PTransform.
CoGroup.Result
Convert	A set of utilities for converting between different objects supporting schemas.
DropFields	A transform to drop fields from a schema.
DropFields.Inner<T>	Implementation class for DropFields.
Filter	A PTransform for filtering a collection of schema types.
Filter.Inner<T>	Implementation of the filter.
Group	A generic grouping transform for schema PCollections.
Group.AggregateCombiner<InputT>	a PTransform that does a combine using an aggregation built up by calls to aggregateField and aggregateFields.
Group.ByFields<InputT>	a PTransform that groups schema elements based on the given fields.
Group.CombineFieldsByFields<InputT>	a PTransform that does a per-key combine using an aggregation built up by calls to aggregateField and aggregateFields.
Group.CombineFieldsByFields.Fanout
Group.CombineFieldsGlobally<InputT>	a PTransform that does a global combine using an aggregation built up by calls to aggregateField and aggregateFields.
Group.CombineGlobally<InputT,OutputT>	a PTransform that does a global combine using a provider Combine.CombineFn.
Group.Global<InputT>	A PTransform for doing global aggregations on schema PCollections.
Join	A transform that performs equijoins across two schema PCollections.
Join.FieldsEqual	Predicate object to specify fields to compare when doing an equi-join.
Join.FieldsEqual.Impl	Implementation class for FieldsEqual.
Join.Impl<LhsT,RhsT>	Implementation class .
RenameFields	A transform for renaming fields inside an existing schema.
RenameFields.Inner<T>	The class implementing the actual PTransform.
SchemaTransform	An abstraction representing schema capable and aware transforms.
Select	A PTransform for selecting a subset of fields from a schema type.
Select.Fields<T>
Select.Flattened<T>	A PTransform representing a flattened schema.
TypedSchemaTransformProvider<ConfigT>	Like SchemaTransformProvider except uses a configuration object instead of Schema and Row.
WithKeys<T>

Enum Summary

Enum	Description
Group.CombineFieldsByFields.Fanout.Kind

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

Defines transforms that work on PCollections with schemas..

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