public static class PCollectionViews.SimplePCollectionView<ElemT,PrimitiveViewT,ViewT,W extends BoundedWindow> extends PValueBase implements PCollectionView<ViewT>
PCollectionView implementations, with additional type parameters that are
not visible at pipeline assembly time when the view is used as a side input.
For internal use only.
| Modifier and Type | Method and Description |
|---|---|
boolean |
equals(@Nullable java.lang.Object other) |
java.util.Map<TupleTag<?>,PValue> |
expand()
|
Coder<?> |
getCoderInternal()
For internal use only.
|
PCollection<?> |
getPCollection()
For internal use only.
|
TupleTag<?> |
getTagInternal()
Returns a unique
TupleTag identifying this PCollectionView. |
ViewFn<PrimitiveViewT,ViewT> |
getViewFn()
For internal use only.
|
WindowingStrategy<?,?> |
getWindowingStrategyInternal()
Returns the
WindowingStrategy of this PCollectionView, which should be that
of the underlying PCollection. |
WindowMappingFn<?> |
getWindowMappingFn()
For internal use only.
|
int |
hashCode() |
java.lang.String |
toString() |
finishSpecifying, finishSpecifyingOutput, getKindString, getName, getPipeline, setNameclone, finalize, getClass, notify, notifyAll, wait, wait, waitfinishSpecifying, getNamefinishSpecifyingOutput, getPipelinegetPipelinepublic ViewFn<PrimitiveViewT,ViewT> getViewFn()
PCollectionViewgetViewFn in interface PCollectionView<ViewT>public WindowMappingFn<?> getWindowMappingFn()
PCollectionViewReturns the WindowMappingFn used to map windows from a main input to the side input
of this PCollectionView.
getWindowMappingFn in interface PCollectionView<ViewT>public PCollection<?> getPCollection()
PCollectionViewGets the PCollection this PCollectionView was created from.
The PCollection may not be available in all contexts.
getPCollection in interface PCollectionView<ViewT>public TupleTag<?> getTagInternal()
TupleTag identifying this PCollectionView.
For internal use only by runner implementors.
getTagInternal in interface PCollectionView<ViewT>public WindowingStrategy<?,?> getWindowingStrategyInternal()
WindowingStrategy of this PCollectionView, which should be that
of the underlying PCollection.
For internal use only by runner implementors.
getWindowingStrategyInternal in interface PCollectionView<ViewT>public Coder<?> getCoderInternal()
PCollectionViewgetCoderInternal in interface PCollectionView<ViewT>public int hashCode()
hashCode in class java.lang.Objectpublic boolean equals(@Nullable java.lang.Object other)
equals in class java.lang.Objectpublic java.lang.String toString()
toString in class PValueBasepublic java.util.Map<TupleTag<?>,PValue> expand()
PValuePOutput into a list of its component output PValues.
PValue expands to itself.
PValues (such as PCollectionTuple or PCollectionList) expands to its component PValue PValues.
Not intended to be invoked directly by user code..