@DefaultAnnotation(value=edu.umd.cs.findbugs.annotations.NonNull.class)

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

Defines transforms that work on PCollections with schemas..

See: Description

Class Summary

Class	Description
Convert	A set of utilities for converting between different objects supporting schemas.
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.ByFields<InputT>	a PTransform that groups schema elements based on the given fields.
Group.CombineByFields<InputT,OutputT>	a PTransform that does a per0-key combine using a specified Combine.CombineFn.
Group.CombineFieldsByFields<InputT>	a PTransform that does a per-key combine using an aggregation built up by calls to aggregateField and aggregateFields.
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.
Select<T>	A PTransform for selecting a subset of fields from a schema type.
Unnest	A PTransform to unnest nested rows.
Unnest.Inner<T>	A PTransform that unnests nested row.

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.