Google Cloud Dataflow SDK for Java, version 1.9.1
Class View.CreatePCollectionView<ElemT,ViewT>
- java.lang.Object
-
- com.google.cloud.dataflow.sdk.transforms.PTransform<PCollection<ElemT>,PCollectionView<ViewT>>
-
- com.google.cloud.dataflow.sdk.transforms.View.CreatePCollectionView<ElemT,ViewT>
-
- Type Parameters:
ElemT
- The type of the elements of the input PCollectionViewT
- The type associated with thePCollectionView
used as a side input
- All Implemented Interfaces:
- HasDisplayData, Serializable
- Enclosing class:
- View
public static class View.CreatePCollectionView<ElemT,ViewT> extends PTransform<PCollection<ElemT>,PCollectionView<ViewT>>
Creates a primitivePCollectionView
.For internal use only by runner implementors.
- See Also:
- Serialized Form
-
-
Field Summary
-
Fields inherited from class com.google.cloud.dataflow.sdk.transforms.PTransform
name
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method and Description PCollectionView<ViewT>
apply(PCollection<ElemT> input)
Applies thisPTransform
on the givenInputT
, and returns itsOutput
.PCollectionView<ViewT>
getView()
static <ElemT,ViewT>
View.CreatePCollectionView<ElemT,ViewT>of(PCollectionView<ViewT> view)
-
Methods inherited from class com.google.cloud.dataflow.sdk.transforms.PTransform
getDefaultOutputCoder, getDefaultOutputCoder, getDefaultOutputCoder, getKindString, getName, populateDisplayData, toString, validate
-
-
-
-
Method Detail
-
of
public static <ElemT,ViewT> View.CreatePCollectionView<ElemT,ViewT> of(PCollectionView<ViewT> view)
-
getView
public PCollectionView<ViewT> getView()
-
apply
public PCollectionView<ViewT> apply(PCollection<ElemT> input)
Description copied from class:PTransform
Applies thisPTransform
on the givenInputT
, and returns itsOutput
.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).
The default implementation throws an exception. A derived class must either implement apply, or else each runner must supply a custom implementation via
PipelineRunner.apply(com.google.cloud.dataflow.sdk.transforms.PTransform<InputT, OutputT>, InputT)
.- Overrides:
apply
in classPTransform<PCollection<ElemT>,PCollectionView<ViewT>>
-
-