Google Cloud Dataflow SDK for Java, version 1.9.1
com.google.cloud.dataflow.sdk.values
Interface PCollectionView<T>
-
- Type Parameters:
T
- the type of the value(s) accessible via thisPCollectionView
- All Superinterfaces:
- PInput, POutput, PValue, Serializable
public interface PCollectionView<T> extends PValue, Serializable
APCollectionView<T>
is an immutable view of aPCollection
as a value of typeT
that can be accessed as a side input to aParDo
transform.A
PCollectionView
should always be the output of aPTransform
. It is the joint responsibility of this transform and eachPipelineRunner
to implement the view in a runner-specific manner.The most common case is using the
View
transforms to prepare aPCollection
for use as a side input toParDo
. SeeView.asSingleton()
,View.asIterable()
, andView.asMap()
for more detail on specific views available in the SDK.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method and Description T
fromIterableInternal(Iterable<com.google.cloud.dataflow.sdk.util.WindowedValue<?>> contents)
For internal use only.Coder<Iterable<com.google.cloud.dataflow.sdk.util.WindowedValue<?>>>
getCoderInternal()
For internal use only.TupleTag<Iterable<com.google.cloud.dataflow.sdk.util.WindowedValue<?>>>
getTagInternal()
A unique identifier, for internal use.com.google.cloud.dataflow.sdk.util.WindowingStrategy<?,?>
getWindowingStrategyInternal()
For internal use only.-
Methods inherited from interface com.google.cloud.dataflow.sdk.values.PValue
getName, getProducingTransformInternal
-
Methods inherited from interface com.google.cloud.dataflow.sdk.values.POutput
expand, finishSpecifyingOutput, getPipeline, recordAsOutput
-
Methods inherited from interface com.google.cloud.dataflow.sdk.values.PInput
expand, finishSpecifying, getPipeline
-
-
-
-
Method Detail
-
getTagInternal
TupleTag<Iterable<com.google.cloud.dataflow.sdk.util.WindowedValue<?>>> getTagInternal()
A unique identifier, for internal use.
-
fromIterableInternal
T fromIterableInternal(Iterable<com.google.cloud.dataflow.sdk.util.WindowedValue<?>> contents)
For internal use only.
-
getWindowingStrategyInternal
com.google.cloud.dataflow.sdk.util.WindowingStrategy<?,?> getWindowingStrategyInternal()
For internal use only.
-
-