Package org.apache.beam.sdk.io.sparkreceiver

Class ReceiverBuilder<X,T extends org.apache.spark.streaming.receiver.Receiver<X>>

java.lang.Object

org.apache.beam.sdk.io.sparkreceiver.ReceiverBuilder<X,T>

All Implemented Interfaces:

Serializable

public class ReceiverBuilder<X,T extends org.apache.spark.streaming.receiver.Receiver<X>>
extends Object
implements Serializable

Class for building an instance for Receiver that uses Apache Beam mechanisms instead of Spark environment.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
ReceiverBuilder(Class<T> sparkReceiverClass)

Method Summary

Modifier and Type	Method	Description
T	build()
Class<T>	getSparkReceiverClass()
ReceiverBuilder<X,T>	withConstructorArgs(Object... args)	Method for specifying constructor arguments for corresponding sparkReceiverClass.

Methods inherited from class java.lang.Object

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

Constructor Details

ReceiverBuilder

public ReceiverBuilder(Class<T> sparkReceiverClass)

Method Details

withConstructorArgs

public ReceiverBuilder<X,T> withConstructorArgs(Object... args)

Method for specifying constructor arguments for corresponding sparkReceiverClass.

build

public T build()
        throws InvocationTargetException,
InstantiationException,
IllegalAccessException

Returns:

Proxy for given that doesn't use Spark environment and uses Apache Beam mechanisms instead.

Throws:

InvocationTargetException

InstantiationException

IllegalAccessException

getSparkReceiverClass

public Class<T> getSparkReceiverClass()