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:

java.io.Serializable

public class ReceiverBuilder<X,T extends org.apache.spark.streaming.receiver.Receiver<X>>
extends java.lang.Object
implements java.io.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 and Description
ReceiverBuilder(java.lang.Class<T> sparkReceiverClass)

Method Summary

Modifier and Type	Method and Description
T	build()
java.lang.Class<T>	getSparkReceiverClass()
ReceiverBuilder<X,T>	withConstructorArgs(java.lang.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 Detail

ReceiverBuilder

public ReceiverBuilder(java.lang.Class<T> sparkReceiverClass)

Method Detail

withConstructorArgs

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

Method for specifying constructor arguments for corresponding sparkReceiverClass.

build

public T build()
        throws java.lang.reflect.InvocationTargetException,
               java.lang.InstantiationException,
               java.lang.IllegalAccessException

Returns:

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

Throws:

java.lang.reflect.InvocationTargetException

java.lang.InstantiationException

java.lang.IllegalAccessException

getSparkReceiverClass

public java.lang.Class<T> getSparkReceiverClass()