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(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, setName
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
finishSpecifying, getName
finishSpecifyingOutput, getPipeline
getPipeline
public ViewFn<PrimitiveViewT,ViewT> getViewFn()
PCollectionView
getViewFn
in interface PCollectionView<ViewT>
public WindowMappingFn<?> getWindowMappingFn()
PCollectionView
Returns 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()
PCollectionView
Gets 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()
PCollectionView
getCoderInternal
in interface PCollectionView<ViewT>
public int hashCode()
hashCode
in class java.lang.Object
public boolean equals(java.lang.Object other)
equals
in class java.lang.Object
public java.lang.String toString()
toString
in class PValueBase
public java.util.Map<TupleTag<?>,PValue> expand()
PValue
POutput
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..