public class RunnerPCollectionView<T> extends PValueBase implements PCollectionView<T>
PCollectionView created from the components of a RunnerApi.SideInput.| Constructor and Description |
|---|
RunnerPCollectionView(@Nullable PCollection<?> pCollection,
TupleTag<java.lang.Iterable<WindowedValue<?>>> tag,
ViewFn<java.lang.Iterable<WindowedValue<?>>,T> viewFn,
WindowMappingFn<?> windowMappingFn,
@Nullable WindowingStrategy<?,?> windowingStrategy,
@Nullable Coder<?> coder)
Create a new
RunnerPCollectionView from the provided components. |
| 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<java.lang.Iterable<WindowedValue<?>>> |
getTagInternal()
For internal use only.
|
ViewFn<java.lang.Iterable<WindowedValue<?>>,T> |
getViewFn()
For internal use only.
|
WindowingStrategy<?,?> |
getWindowingStrategyInternal()
For internal use only.
|
WindowMappingFn<?> |
getWindowMappingFn()
For internal use only.
|
int |
hashCode() |
finishSpecifying, finishSpecifyingOutput, getKindString, getName, getPipeline, setName, toStringclone, finalize, getClass, notify, notifyAll, wait, wait, waitfinishSpecifying, getNamefinishSpecifyingOutput, getPipelinegetPipelinepublic RunnerPCollectionView(@Nullable PCollection<?> pCollection, TupleTag<java.lang.Iterable<WindowedValue<?>>> tag, ViewFn<java.lang.Iterable<WindowedValue<?>>,T> viewFn, WindowMappingFn<?> windowMappingFn, @Nullable WindowingStrategy<?,?> windowingStrategy, @Nullable Coder<?> coder)
RunnerPCollectionView from the provided components.public PCollection<?> getPCollection()
PCollectionViewGets the PCollection this PCollectionView was created from.
The PCollection may not be available in all contexts.
getPCollection in interface PCollectionView<T>public TupleTag<java.lang.Iterable<WindowedValue<?>>> getTagInternal()
PCollectionViewgetTagInternal in interface PCollectionView<T>public ViewFn<java.lang.Iterable<WindowedValue<?>>,T> getViewFn()
PCollectionViewgetViewFn in interface PCollectionView<T>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<T>public WindowingStrategy<?,?> getWindowingStrategyInternal()
PCollectionViewgetWindowingStrategyInternal in interface PCollectionView<T>public Coder<?> getCoderInternal()
PCollectionViewgetCoderInternal in interface PCollectionView<T>public 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..
public boolean equals(@Nullable java.lang.Object other)
equals in class java.lang.Objectpublic int hashCode()
hashCode in class java.lang.Object