Package org.apache.beam.runners.spark.translation

Class SparkPCollectionView

java.lang.Object

org.apache.beam.runners.spark.translation.SparkPCollectionView

All Implemented Interfaces:

Serializable

public class SparkPCollectionView
extends Object
implements Serializable

SparkPCollectionView is used to pass serialized views to lambdas.

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	SparkPCollectionView.Type	Type of side input.

Constructor Summary

Constructors

Constructor	Description
SparkPCollectionView()

Method Summary

Modifier and Type	Method	Description
void	putPView(PCollectionView<?> view, Iterable<WindowedValue<?>> value, Coder<Iterable<WindowedValue<?>>> coder)
void	putStreamingPView(PCollectionView<?> view, Iterable<WindowedValue<?>> value, Coder<Iterable<WindowedValue<?>>> coder)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

SparkPCollectionView

public SparkPCollectionView()

Method Details

putPView

public void putPView(PCollectionView<?> view,
 Iterable<WindowedValue<?>> value,
 Coder<Iterable<WindowedValue<?>>> coder)

putStreamingPView

public void putStreamingPView(PCollectionView<?> view,
 Iterable<WindowedValue<?>> value,
 Coder<Iterable<WindowedValue<?>>> coder)