org.apache.beam.sdk.values

Class PCollectionViews.SimplePCollectionView<ElemT,ViewT,W extends BoundedWindow>

java.lang.Object

org.apache.beam.sdk.values.PValueBase

org.apache.beam.sdk.values.PCollectionViews.SimplePCollectionView<ElemT,ViewT,W>

All Implemented Interfaces:

java.io.Serializable, PCollectionView<ViewT>, PInput, POutput, PValue

Enclosing class:

PCollectionViews

public static class PCollectionViews.SimplePCollectionView<ElemT,ViewT,W extends BoundedWindow>
extends PValueBase
implements PCollectionView<ViewT>

A class for 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.

See Also:

Serialized Form

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SimplePCollectionView() For serialization only.

Method Summary

Modifier and Type	Method and Description
boolean	equals(java.lang.Object other)
java.util.Map<TupleTag<?>,PValue>	expand() Expands this POutput into a list of its component output PValues.
Coder<java.lang.Iterable<org.apache.beam.sdk.util.WindowedValue<?>>>	getCoderInternal() For internal use only.
PCollection<?>	getPCollection() For internal use only.
TupleTag<java.lang.Iterable<org.apache.beam.sdk.util.WindowedValue<?>>>	getTagInternal() Returns a unique TupleTag identifying this PCollectionView.
ViewFn<java.lang.Iterable<org.apache.beam.sdk.util.WindowedValue<?>>,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()

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.PValue

finishSpecifying, getName

Methods inherited from interface org.apache.beam.sdk.values.POutput

finishSpecifyingOutput, getPipeline

Methods inherited from interface org.apache.beam.sdk.values.PInput

getPipeline

Constructor Detail

SimplePCollectionView

protected SimplePCollectionView()

For serialization only. Do not use directly.

Method Detail

getViewFn

public ViewFn<java.lang.Iterable<org.apache.beam.sdk.util.WindowedValue<?>>,ViewT> getViewFn()

Description copied from interface: PCollectionView

For internal use only.

Specified by:

getViewFn in interface PCollectionView<ViewT>

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 this PCollectionView.

Specified by:

getWindowMappingFn in interface PCollectionView<ViewT>

getPCollection

public PCollection<?> getPCollection()

Description copied from interface: PCollectionView

For internal use only.

Gets the PCollection this PCollectionView was created from.

The PCollection may not be available in all contexts.

Specified by:

getPCollection in interface PCollectionView<ViewT>

getTagInternal

public TupleTag<java.lang.Iterable<org.apache.beam.sdk.util.WindowedValue<?>>> getTagInternal()

Returns a unique TupleTag identifying this PCollectionView.

For internal use only by runner implementors.

Specified by:

getTagInternal in interface PCollectionView<ViewT>

getWindowingStrategyInternal

public WindowingStrategy<?,?> getWindowingStrategyInternal()

Returns the WindowingStrategy of this PCollectionView, which should be that of the underlying PCollection.

For internal use only by runner implementors.

Specified by:

getWindowingStrategyInternal in interface PCollectionView<ViewT>

getCoderInternal

public Coder<java.lang.Iterable<org.apache.beam.sdk.util.WindowedValue<?>>> getCoderInternal()

Description copied from interface: PCollectionView

For internal use only.

Specified by:

getCoderInternal in interface PCollectionView<ViewT>

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

equals

public boolean equals(java.lang.Object other)

Overrides:

equals in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class PValueBase

expand

public java.util.Map<TupleTag<?>,PValue> expand()

Description copied from interface: PValue

Expands this POutput into a list of its component output PValues.

• A PValue expands to itself.
• A tuple or list of PValues (such as PCollectionTuple or PCollectionList) expands to its component PValue PValues.

Not intended to be invoked directly by user code..

A PValue always expands into itself. Calling PValue.expand() on a PValue is almost never appropriate.

Specified by:

expand in interface PInput

Specified by:

expand in interface POutput

Specified by:

expand in interface PValue