Package org.apache.beam.sdk.values
Class PCollectionViews.SimplePCollectionView<ElemT,PrimitiveViewT,ViewT,W extends BoundedWindow>
- java.lang.Object
-
- org.apache.beam.sdk.values.PValueBase
-
- org.apache.beam.sdk.values.PCollectionViews.SimplePCollectionView<ElemT,PrimitiveViewT,ViewT,W>
-
- All Implemented Interfaces:
java.io.Serializable
,PCollectionView<ViewT>
,PInput
,POutput
,PValue
- Enclosing class:
- PCollectionViews
public static class PCollectionViews.SimplePCollectionView<ElemT,PrimitiveViewT,ViewT,W extends BoundedWindow> extends PValueBase implements PCollectionView<ViewT>
A class forPCollectionView
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.
- See Also:
- Serialized Form
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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 uniqueTupleTag
identifying thisPCollectionView
.ViewFn<PrimitiveViewT,ViewT>
getViewFn()
For internal use only.WindowingStrategy<?,?>
getWindowingStrategyInternal()
Returns theWindowingStrategy
of thisPCollectionView
, which should be that of the underlyingPCollection
.WindowMappingFn<?>
getWindowMappingFn()
For internal use only.int
hashCode()
java.lang.String
toString()
-
Methods inherited from class org.apache.beam.sdk.values.PValueBase
finishSpecifying, finishSpecifyingOutput, getKindString, getName, getPipeline, setName
-
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface org.apache.beam.sdk.values.PInput
getPipeline
-
Methods inherited from interface org.apache.beam.sdk.values.POutput
finishSpecifyingOutput, getPipeline
-
Methods inherited from interface org.apache.beam.sdk.values.PValue
finishSpecifying, getName
-
-
-
-
Method Detail
-
getViewFn
public ViewFn<PrimitiveViewT,ViewT> getViewFn()
Description copied from interface:PCollectionView
For internal use only.- Specified by:
getViewFn
in interfacePCollectionView<ElemT>
-
getWindowMappingFn
public WindowMappingFn<?> getWindowMappingFn()
Description copied from interface:PCollectionView
For internal use only.Returns the
WindowMappingFn
used to map windows from a main input to the side input of thisPCollectionView
.- Specified by:
getWindowMappingFn
in interfacePCollectionView<ElemT>
-
getPCollection
public PCollection<?> getPCollection()
Description copied from interface:PCollectionView
For internal use only.Gets the
PCollection
thisPCollectionView
was created from.The
PCollection
may not be available in all contexts.- Specified by:
getPCollection
in interfacePCollectionView<ElemT>
-
getTagInternal
public TupleTag<?> getTagInternal()
Returns a uniqueTupleTag
identifying thisPCollectionView
.For internal use only by runner implementors.
- Specified by:
getTagInternal
in interfacePCollectionView<ElemT>
-
getWindowingStrategyInternal
public WindowingStrategy<?,?> getWindowingStrategyInternal()
Returns theWindowingStrategy
of thisPCollectionView
, which should be that of the underlyingPCollection
.For internal use only by runner implementors.
- Specified by:
getWindowingStrategyInternal
in interfacePCollectionView<ElemT>
-
getCoderInternal
public Coder<?> getCoderInternal()
Description copied from interface:PCollectionView
For internal use only.- Specified by:
getCoderInternal
in interfacePCollectionView<ElemT>
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
equals
public boolean equals(@Nullable java.lang.Object other)
- Overrides:
equals
in classjava.lang.Object
-
toString
public java.lang.String toString()
- Overrides:
toString
in classPValueBase
-
expand
public java.util.Map<TupleTag<?>,PValue> expand()
Description copied from interface:PValue
Expands thisPOutput
into a list of its component outputPValues
.- A
PValue
expands to itself. - A tuple or list of
PValues
(such asPCollectionTuple
orPCollectionList
) expands to its componentPValue PValues
.
Not intended to be invoked directly by user code..
- A
-
-