Package org.apache.beam.sdk.transforms.join

package org.apache.beam.sdk.transforms.join

Defines the CoGroupByKey transform for joining multiple PCollections.

Related Packages

Package	Description
org.apache.beam.sdk.transforms	Defines PTransforms for transforming data in a pipeline.
org.apache.beam.sdk.transforms.display	Defines HasDisplayData for annotating components which provide display data used within UIs and diagnostic tools.
org.apache.beam.sdk.transforms.errorhandling	Provides utilities for handling errors in Pipelines.
org.apache.beam.sdk.transforms.resourcehints	Defines ResourceHints for configuring pipeline execution.
org.apache.beam.sdk.transforms.splittabledofn	Defines utilities related to splittable DoFn.
org.apache.beam.sdk.transforms.windowing	Defines the Window transform for dividing the elements in a PCollection into windows, and the Trigger for controlling when those elements are output.

Classes

Class	Description
CoGbkResult	A row result of a CoGroupByKey.
CoGbkResult.CoGbkResultCoder	A Coder for CoGbkResults.
CoGbkResultSchema	A schema for the results of a CoGroupByKey.
CoGroupByKey<K>	A PTransform that performs a CoGroupByKey on a tuple of tables.
KeyedPCollectionTuple<K>	An immutable tuple of keyed PCollections with key type K.
KeyedPCollectionTuple.TaggedKeyedPCollection<K,V>	A utility class to help ensure coherence of tag and input PCollection types.
RawUnionValue	This corresponds to an integer union tag and value.
UnionCoder	A UnionCoder encodes RawUnionValues.