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 java.lang.Object

Builder class for a Plugin.

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
abstract Plugin<K,V>	build()
abstract Plugin.Builder<K,V>	setContext(BatchContextImpl context)
abstract Plugin.Builder<K,V>	setFormatClass(java.lang.Class<?> newFormatClass)
abstract Plugin.Builder<K,V>	setFormatProviderClass(java.lang.Class<?> newFormatProviderClass)
abstract Plugin.Builder<K,V>	setGetOffsetFn(SerializableFunction<V,java.lang.Long> getOffsetFn)
abstract Plugin.Builder<K,V>	setGetReceiverArgsFromConfigFn(SerializableFunction<PluginConfig,java.lang.Object[]> getReceiverArgsFromConfigFn)
abstract Plugin.Builder<K,V>	setPluginClass(java.lang.Class<?> newPluginClass)
abstract Plugin.Builder<K,V>	setPluginType(PluginConstants.PluginType newPluginType)
abstract Plugin.Builder<K,V>	setReceiverClass(java.lang.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 Detail

Builder

public Builder()

Method Detail

setPluginClass

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

setFormatClass

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

setFormatProviderClass

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

setGetOffsetFn

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

setGetReceiverArgsFromConfigFn

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

setReceiverClass

public abstract Plugin.Builder<K,V> setReceiverClass(java.lang.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()