Package org.apache.beam.sdk.io.cdap

Class Plugin.Builder<K,V>

java.lang.Object

org.apache.beam.sdk.io.cdap.Plugin.Builder<K,V>

Enclosing class:

Plugin<K,V>

public abstract static class Plugin.Builder<K,V>
extends Object

Builder class for a Plugin.

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
abstract Plugin<K,V>	build()
abstract Plugin.Builder<K,V>	setContext(BatchContextImpl context)
abstract Plugin.Builder<K,V>	setFormatClass(Class<?> newFormatClass)
abstract Plugin.Builder<K,V>	setFormatProviderClass(Class<?> newFormatProviderClass)
abstract Plugin.Builder<K,V>	setGetOffsetFn(SerializableFunction<V,Long> getOffsetFn)
abstract Plugin.Builder<K,V>	setGetReceiverArgsFromConfigFn(SerializableFunction<PluginConfig,Object[]> getReceiverArgsFromConfigFn)
abstract Plugin.Builder<K,V>	setPluginClass(Class<?> newPluginClass)
abstract Plugin.Builder<K,V>	setPluginType(PluginConstants.PluginType newPluginType)
abstract Plugin.Builder<K,V>	setReceiverClass(Class<? extends org.apache.spark.streaming.receiver.Receiver<V>> receiverClass)

Methods inherited from class java.lang.Object

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

Constructor Details

Builder

public Builder()

Method Details

setPluginClass

public abstract Plugin.Builder<K,V> setPluginClass(Class<?> newPluginClass)

setFormatClass

public abstract Plugin.Builder<K,V> setFormatClass(Class<?> newFormatClass)

setFormatProviderClass

public abstract Plugin.Builder<K,V> setFormatProviderClass(Class<?> newFormatProviderClass)

setGetOffsetFn

public abstract Plugin.Builder<K,V> setGetOffsetFn(SerializableFunction<V,Long> getOffsetFn)

setGetReceiverArgsFromConfigFn

public abstract Plugin.Builder<K,V> setGetReceiverArgsFromConfigFn(SerializableFunction<PluginConfig,Object[]> getReceiverArgsFromConfigFn)

setReceiverClass

public abstract Plugin.Builder<K,V> setReceiverClass(Class<? extends org.apache.spark.streaming.receiver.Receiver<V>> receiverClass)

setPluginType

public abstract Plugin.Builder<K,V> setPluginType(PluginConstants.PluginType newPluginType)

setContext

public abstract Plugin.Builder<K,V> setContext(BatchContextImpl context)

build

public abstract Plugin<K,V> build()