Package org.apache.beam.runners.spark.util

Class SideInputBroadcast<T>

java.lang.Object

org.apache.beam.runners.spark.util.SideInputBroadcast<T>

All Implemented Interfaces:

Serializable

public class SideInputBroadcast<T>
extends Object
implements Serializable

Broadcast helper for side inputs. Helps to do the transformation from bytes transform to broadcast transform to value by coder

See Also:

• Serialized Form

Method Summary

Modifier and Type	Method	Description
void	broadcast(org.apache.spark.api.java.JavaSparkContext jsc)
static <T> SideInputBroadcast<T>	create(byte[] bytes, SparkPCollectionView.Type type, Coder<T> coder)
long	getBroadcastSizeEstimate()
SparkPCollectionView.Type	getSparkPCollectionViewType()
T	getValue()
void	unpersist()

Methods inherited from class java.lang.Object

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

Method Details

create

public static <T> SideInputBroadcast<T> create(byte[] bytes,
 SparkPCollectionView.Type type,
 Coder<T> coder)

getValue

public T getValue()

broadcast

public void broadcast(org.apache.spark.api.java.JavaSparkContext jsc)

getSparkPCollectionViewType

public SparkPCollectionView.Type getSparkPCollectionViewType()

unpersist

public void unpersist()

getBroadcastSizeEstimate

public long getBroadcastSizeEstimate()