public class PCollectionTuple extends java.lang.Object implements PInput, POutput
PCollectionTuple is an immutable tuple of
heterogeneously-typed PCollections, "keyed" by
TupleTags. A PCollectionTuple can be used as the input or
output of a
PTransform taking
or producing multiple PCollection inputs or outputs that can be of
different types, for instance a
ParDo with multiple outputs.
A PCollectionTuple can be created and accessed like follows:
PCollection<String> pc1 = ...;
PCollection<Integer> pc2 = ...;
PCollection<Iterable<String>> pc3 = ...;
// Create TupleTags for each of the PCollections to put in the
// PCollectionTuple (the type of the TupleTag enables tracking the
// static type of each of the PCollections in the PCollectionTuple):
TupleTag<String> tag1 = new TupleTag<>();
TupleTag<Integer> tag2 = new TupleTag<>();
TupleTag<Iterable<String>> tag3 = new TupleTag<>();
// Create a PCollectionTuple with three PCollections:
PCollectionTuple pcs =
PCollectionTuple.of(tag1, pc1)
.and(tag2, pc2)
.and(tag3, pc3);
// Create an empty PCollectionTuple:
Pipeline p = ...;
PCollectionTuple pcs2 = PCollectionTuple.empty(p);
// Get PCollections out of a PCollectionTuple, using the same tags
// that were used to put them in:
PCollection<Integer> pcX = pcs.get(tag2);
PCollection<String> pcY = pcs.get(tag1);
PCollection<Iterable<String>> pcZ = pcs.get(tag3);
// Get a map of all PCollections in a PCollectionTuple:
Map<TupleTag<?>, PCollection<?>> allPcs = pcs.getAll();
| Modifier and Type | Method and Description |
|---|---|
<T> PCollectionTuple |
and(TupleTag<T> tag,
PCollection<T> pc)
Returns a new
PCollectionTuple that has each PCollection and
TupleTag of this PCollectionTuple plus the given PCollection
associated with the given TupleTag. |
<OutputT extends POutput> |
apply(PTransform<PCollectionTuple,OutputT> t)
Like
apply(String, PTransform) but defaulting to the name
of the PTransform. |
<OutputT extends POutput> |
apply(java.lang.String name,
PTransform<PCollectionTuple,OutputT> t)
Applies the given
PTransform to this input PCollectionTuple,
using name to identify this specific application of the transform. |
static PCollectionTuple |
empty(Pipeline pipeline)
Returns an empty
PCollectionTuple that is part of the given Pipeline. |
boolean |
equals(java.lang.Object other) |
java.util.Map<TupleTag<?>,PValue> |
expand()
|
void |
finishSpecifyingOutput(java.lang.String transformName,
PInput input,
PTransform<?,?> transform)
As part of applying the producing
PTransform, finalizes this output to make it ready
for being used as an input and for running. |
<T> PCollection<T> |
get(TupleTag<T> tag)
|
java.util.Map<TupleTag<?>,PCollection<?>> |
getAll()
Returns an immutable Map from
TupleTag to corresponding
PCollection, for all the members of this PCollectionTuple. |
Pipeline |
getPipeline()
|
<T> boolean |
has(TupleTag<T> tag)
Returns whether this
PCollectionTuple contains a PCollection with
the given tag. |
int |
hashCode() |
static <T> PCollectionTuple |
of(TupleTag<T> tag,
PCollection<T> pc)
|
static PCollectionTuple |
ofPrimitiveOutputsInternal(Pipeline pipeline,
TupleTagList outputTags,
WindowingStrategy<?,?> windowingStrategy,
PCollection.IsBounded isBounded)
For internal use only; no backwards-compatibility guarantees.
|
public static PCollectionTuple empty(Pipeline pipeline)
PCollectionTuple that is part of the given Pipeline.
A PCollectionTuple containing additional elements can be created by calling
and(org.apache.beam.sdk.values.TupleTag<T>, org.apache.beam.sdk.values.PCollection<T>) on the result.
public static <T> PCollectionTuple of(TupleTag<T> tag, PCollection<T> pc)
PCollectionTuple containing the given
PCollection keyed by the given TupleTag.
A PCollectionTuple containing additional elements can be created by calling
and(org.apache.beam.sdk.values.TupleTag<T>, org.apache.beam.sdk.values.PCollection<T>) on the result.
public <T> PCollectionTuple and(TupleTag<T> tag, PCollection<T> pc)
PCollectionTuple that has each PCollection and
TupleTag of this PCollectionTuple plus the given PCollection
associated with the given TupleTag.
The given TupleTag should not already be mapped to a
PCollection in this PCollectionTuple.
Each PCollection in the resulting PCollectionTuple must be
part of the same Pipeline.
public <T> boolean has(TupleTag<T> tag)
PCollectionTuple contains a PCollection with
the given tag.public <T> PCollection<T> get(TupleTag<T> tag)
PCollection associated with the given TupleTag
in this PCollectionTuple. Throws IllegalArgumentException if there is no
such PCollection, i.e., !has(tag).public java.util.Map<TupleTag<?>,PCollection<?>> getAll()
TupleTag to corresponding
PCollection, for all the members of this PCollectionTuple.public <OutputT extends POutput> OutputT apply(PTransform<PCollectionTuple,OutputT> t)
apply(String, PTransform) but defaulting to the name
of the PTransform.PTransformpublic <OutputT extends POutput> OutputT apply(java.lang.String name, PTransform<PCollectionTuple,OutputT> t)
PTransform to this input PCollectionTuple,
using name to identify this specific application of the transform.
This name is used in various places, including the monitoring UI, logging,
and to stably identify this application node in the job graph.PTransform@Internal public static PCollectionTuple ofPrimitiveOutputsInternal(Pipeline pipeline, TupleTagList outputTags, WindowingStrategy<?,?> windowingStrategy, PCollection.IsBounded isBounded)
Returns a PCollectionTuple with each of the given tags mapping to a new
output PCollection.
For use by primitive transformations only.
public Pipeline getPipeline()
PInputgetPipeline in interface PInputgetPipeline in interface POutputpublic java.util.Map<TupleTag<?>,PValue> expand()
PInputPInput into a list of its component output
PValues.
PValue expands to itself.PValues (such as
PCollectionTuple or PCollectionList)
expands to its component PValue PValues.Not intended to be invoked directly by user code.
public void finishSpecifyingOutput(java.lang.String transformName,
PInput input,
PTransform<?,?> transform)
POutputPTransform, finalizes this output to make it ready
for being used as an input and for running.
This includes ensuring that all PCollections have Coders specified or defaulted.
Automatically invoked whenever this POutput is output, after
POutput.finishSpecifyingOutput(String, PInput, PTransform) has been called on each
component PValue returned by POutput.expand().
finishSpecifyingOutput in interface POutputpublic boolean equals(java.lang.Object other)
equals in class java.lang.Objectpublic int hashCode()
hashCode in class java.lang.Object