CoGroupByKey transform
for joining multiple PCollections.See: Description
| 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 transform that performs a CoGroupByKey on a tuple of tables.
|
| KeyedPCollectionTuple<K> |
Represents an immutable tuple of keyed PCollections (i.e.
|
| 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.
|
CoGroupByKey transform
for joining multiple PCollections.