@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.
-
Interface Summary Interface Description Cast.Validator Interface for statically validating casts.SchemaTransform An abstraction to create schema capable and aware transforms.SchemaTransformProvider Provider to createSchemaTransform
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 schemaPCollection
s.CoGroup.By Defines the set of fields to extract for the join key, as well as other per-input join options.CoGroup.ExpandCrossProduct APTransform
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 APTransform
for filtering a collection of schema types.Filter.Inner<T> Implementation of the filter.Group A generic grouping transform for schemaPCollection
s.Group.AggregateCombiner<InputT> aPTransform
that does a combine using an aggregation built up by calls to aggregateField and aggregateFields.Group.ByFields<InputT> aPTransform
that groups schema elements based on the given fields.Group.CombineFieldsByFields<InputT> aPTransform
that does a per-key combine using an aggregation built up by calls to aggregateField and aggregateFields.Group.CombineFieldsGlobally<InputT> aPTransform
that does a global combine using an aggregation built up by calls to aggregateField and aggregateFields.Group.CombineGlobally<InputT,OutputT> aPTransform
that does a global combine using a providerCombine.CombineFn
.Group.Global<InputT> APTransform
for doing global aggregations on schema PCollections.Join A transform that performs equijoins across two schemaPCollection
s.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.Select APTransform
for selecting a subset of fields from a schema type.Select.Fields<T> Select.Flattened<T> APTransform
representing a flattened schema.TypedSchemaTransformProvider<ConfigT> LikeSchemaTransformProvider
except uses a configuration object instead of Schema and Row.WithKeys<T>