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

Class ConfigWrapper<T extends PluginConfig>

java.lang.Object

org.apache.beam.sdk.io.cdap.ConfigWrapper<T>

public class ConfigWrapper<T extends PluginConfig>
extends Object

Class for building PluginConfig object of the specific class .

Constructor Summary

Constructors

Constructor	Description
ConfigWrapper(Class<T> configClass)

Method Summary

Modifier and Type	Method	Description
T	build()
ConfigWrapper<T>	fromJsonFile(File jsonFile)	Gets ConfigWrapper by JSON file.
ConfigWrapper<T>	fromJsonString(String jsonString)	Gets ConfigWrapper by JSON string.
ConfigWrapper<T>	setParam(String paramName, Object param)	Sets a Plugin single parameter.
ConfigWrapper<T>	withParams(Map<String,Object> paramsMap)	Sets a Plugin parameters Map.

Methods inherited from class java.lang.Object

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

Constructor Details

ConfigWrapper

public ConfigWrapper(Class<T> configClass)

Method Details

fromJsonString

public ConfigWrapper<T> fromJsonString(String jsonString)
                                throws IOException

Gets ConfigWrapper by JSON string.

Throws:

IOException

fromJsonFile

public ConfigWrapper<T> fromJsonFile(File jsonFile)
                              throws IOException

Gets ConfigWrapper by JSON file.

Throws:

IOException

withParams

public ConfigWrapper<T> withParams(Map<String,Object> paramsMap)

Sets a Plugin parameters Map.

setParam

public ConfigWrapper<T> setParam(String paramName,
 Object param)

Sets a Plugin single parameter.

build

@Nullable
public T build()