ElemT
- The type of the elements of the input PCollectionViewT
- The type associated with the PCollectionView
used as a side input@Internal public static class View.CreatePCollectionView<ElemT,ViewT> extends PTransform<PCollection<ElemT>,PCollection<ElemT>>
Placeholder transform for runners to have a hook to materialize a PCollection
as a
side input. The metadata included in the PCollectionView
is how the PCollection
will be read as a side input.
annotations, displayData, name, resourceHints
Modifier and Type | Method and Description |
---|---|
PCollection<ElemT> |
expand(PCollection<ElemT> input)
Override this method to specify how this
PTransform should be expanded on the given
InputT . |
PCollectionView<ViewT> |
getView()
Deprecated.
This should not be used to obtain the output of any given application of this
PTransform . That should be obtained by inspecting the TransformHierarchy.Node that contains
this View.CreatePCollectionView , as this view may have been replaced within pipeline
surgery. |
static <ElemT,ViewT> |
of(PCollectionView<ViewT> view) |
addAnnotation, compose, compose, getAdditionalInputs, getAnnotations, getDefaultOutputCoder, getDefaultOutputCoder, getDefaultOutputCoder, getKindString, getName, getResourceHints, populateDisplayData, setDisplayData, setResourceHints, toString, validate, validate
public static <ElemT,ViewT> View.CreatePCollectionView<ElemT,ViewT> of(PCollectionView<ViewT> view)
@Deprecated public PCollectionView<ViewT> getView()
PTransform
. That should be obtained by inspecting the TransformHierarchy.Node
that contains
this View.CreatePCollectionView
, as this view may have been replaced within pipeline
surgery.PCollectionView
that is returned by applying this PTransform
.public PCollection<ElemT> expand(PCollection<ElemT> input)
PTransform
PTransform
should be expanded on the given
InputT
.
NOTE: This method should not be called directly. Instead apply the PTransform
should
be applied to the InputT
using the apply
method.
Composite transforms, which are defined in terms of other transforms, should return the output of one of the composed transforms. Non-composite transforms, which do not apply any transforms internally, should return a new unbound output and register evaluators (via backend-specific registration methods).
expand
in class PTransform<PCollection<ElemT>,PCollection<ElemT>>