Class KeyedPCollectionTuple.TaggedKeyedPCollection<K,V>
- java.lang.Object
-
- org.apache.beam.sdk.transforms.join.KeyedPCollectionTuple.TaggedKeyedPCollection<K,V>
-
- Enclosing class:
- KeyedPCollectionTuple<K>
public static class KeyedPCollectionTuple.TaggedKeyedPCollection<K,V> extends java.lang.Object
A utility class to help ensure coherence of tag and input PCollection types.
-
-
Constructor Summary
Constructors Constructor Description TaggedKeyedPCollection(TupleTag<V> tupleTag, PCollection<KV<K,V>> pCollection)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description PCollection<KV<K,V>>
getCollection()
Returns the underlying PCollection of this TaggedKeyedPCollection.TupleTag<V>
getTupleTag()
Returns the TupleTag of this TaggedKeyedPCollection.
-