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

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

Defines transforms that work on PCollections with schemas..

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

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.transforms.providers	Defines transforms that work on PCollections with schemas..
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.utils	Defines utilities for deailing with schemas.

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.Validator	Interface for statically validating casts.
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.CombineFieldsByFields.Fanout.Kind
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.
SchemaTransformProvider	Provider to create SchemaTransform instances for use in Beam SQL and other SDKs.
SchemaTransformTranslation	A PTransformTranslation.TransformPayloadTranslator implementation that translates between a Java SchemaTransform and a protobuf payload for that transform.
SchemaTransformTranslation.SchemaTransformPayloadTranslator<T extends SchemaTransform>
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>