Package 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
All Methods Static Methods Concrete Methods Modifier and Type Method 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 taggedPCollections
represented in the givenPValue
.
-
-
-
Method Detail
-
fullyExpand
public static java.util.Map<TupleTag<?>,PCollection<?>> fullyExpand(java.util.Map<TupleTag<?>,PValue> partiallyExpanded)
Returns all the taggedPCollections
represented in the givenPValue
.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 byPCollection.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 aPCollection
or aPCollectionView
for each PValue. PCollection's expand to themselves andPCollectionView
expands to thePCollection
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)
-
-