org.apache.beam.sdk.values

Class PValues

java.lang.Object

org.apache.beam.sdk.values.PValues

@Internal
public class PValues
extends java.lang.Object

For internal use. No backwards compatibility guarantees.

A primitive value within Beam.

Method Summary

Modifier and Type	Method and Description
static java.util.Map<TupleTag<?>,PCollection<?>>	expandInput(PInput input)
static java.util.Map<TupleTag<?>,PCollection<?>>	expandOutput(POutput output)
static java.util.Map<TupleTag<?>,PCollection<?>>	expandValue(PValue value)
static java.util.Map<TupleTag<?>,PCollection<?>>	fullyExpand(java.util.Map<TupleTag<?>,PValue> partiallyExpanded) Returns all the tagged PCollections represented in the given PValue.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

fullyExpand

public static java.util.Map<TupleTag<?>,PCollection<?>> fullyExpand(java.util.Map<TupleTag<?>,PValue> partiallyExpanded)

Returns all the tagged PCollections represented in the given PValue.

For backwards-compatibility, PCollectionView is still a "PValue" to users, which occurs in only these places:

• POutput.expand() (users can write custom POutputs)
• PInput.expand() (users can write custom PInputs)
• PTransform.getAdditionalInputs() (users can have their composites report inputs not passed by PCollection.apply(org.apache.beam.sdk.transforms.PTransform<? super org.apache.beam.sdk.values.PCollection<T>, OutputT>))

These all return Map<TupleTag<?> PValue>. A user's implementation of these methods is permitted to return either a PCollection or a PCollectionView for each PValue. PCollection's expand to themselves and PCollectionView expands to the PCollection that it is a view of.

expandOutput

public static java.util.Map<TupleTag<?>,PCollection<?>> expandOutput(POutput output)

expandInput

public static java.util.Map<TupleTag<?>,PCollection<?>> expandInput(PInput input)

expandValue

public static java.util.Map<TupleTag<?>,PCollection<?>> expandValue(PValue value)