Package org.apache.beam.sdk.values

Class PValues

java.lang.Object

org.apache.beam.sdk.values.PValues

@Internal
public class PValues
extends Object

For internal use. No backwards compatibility guarantees.

A primitive value within Beam.

Method Summary

Modifier and Type	Method	Description
static Map<TupleTag<?>,PCollection<?>>	expandInput(PInput input)
static Map<TupleTag<?>,PCollection<?>>	expandOutput(POutput output)
static Map<TupleTag<?>,PCollection<?>>	expandValue(PValue value)
static Map<TupleTag<?>,PCollection<?>>	fullyExpand(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 Details

fullyExpand

public static Map<TupleTag<?>,PCollection<?>> fullyExpand(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 Map<TupleTag<?>,PCollection<?>> expandOutput(POutput output)

expandInput

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

expandValue

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