co.cask.cdap.etl.mock.common

Class MockPipelineConfigurer

java.lang.Object

co.cask.cdap.etl.mock.common.MockPipelineConfigurer

All Implemented Interfaces:

DatasetConfigurer, PluginConfigurer, PipelineConfigurer

public class MockPipelineConfigurer
extends Object
implements PipelineConfigurer, DatasetConfigurer

Mock test configurer used to test configure pipeline's validation of input schema and setting of output shcema.

Constructor Summary

Constructors

Constructor and Description
MockPipelineConfigurer(co.cask.cdap.api.data.schema.Schema inputSchema)
MockPipelineConfigurer(co.cask.cdap.api.data.schema.Schema inputSchema, Map<String,Object> plugins) Creates a mock pipeline configurer with a map of plugins to use for validation.

Method Summary

Modifier and Type	Method and Description
void	addDatasetModule(String s, Class<? extends DatasetModule> aClass)
void	addDatasetType(Class<? extends Dataset> aClass)
void	addStream(Stream stream)
void	addStream(String s)
void	createDataset(String s, Class<? extends Dataset> aClass)
void	createDataset(String s, Class<? extends Dataset> aClass, DatasetProperties datasetProperties)
void	createDataset(String s, String s1)
void	createDataset(String s, String s1, DatasetProperties datasetProperties)
Engine	getEngine()
co.cask.cdap.api.data.schema.Schema	getOutputSchema()
StageConfigurer	getStageConfigurer()
void	setPipelineProperties(Map<String,String> properties)
<T> T	usePlugin(String pluginType, String pluginName, String pluginId, PluginProperties pluginProperties, PluginSelector pluginSelector)
<T> Class<T>	usePluginClass(String pluginType, String pluginName, String pluginId, PluginProperties pluginProperties, PluginSelector pluginSelector)

Methods inherited from class java.lang.Object

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

Methods inherited from interface co.cask.cdap.api.plugin.PluginConfigurer

usePlugin, usePluginClass

Constructor Detail

MockPipelineConfigurer

public MockPipelineConfigurer(co.cask.cdap.api.data.schema.Schema inputSchema,
                              Map<String,Object> plugins)

Creates a mock pipeline configurer with a map of plugins to use for validation.

Parameters:

inputSchema - The input schema to use for validation

plugins - A map from plugin ID strings to plugin objects to use

MockPipelineConfigurer

public MockPipelineConfigurer(co.cask.cdap.api.data.schema.Schema inputSchema)

Method Detail

getOutputSchema

@Nullable
public co.cask.cdap.api.data.schema.Schema getOutputSchema()

getStageConfigurer

public StageConfigurer getStageConfigurer()

Specified by:

getStageConfigurer in interface PipelineConfigurer

getEngine

public Engine getEngine()

Specified by:

getEngine in interface PipelineConfigurer

setPipelineProperties

public void setPipelineProperties(Map<String,String> properties)

Specified by:

setPipelineProperties in interface PipelineConfigurer

usePlugin

@Nullable
public <T> T usePlugin(String pluginType,
                                 String pluginName,
                                 String pluginId,
                                 PluginProperties pluginProperties,
                                 PluginSelector pluginSelector)

Specified by:

usePlugin in interface PluginConfigurer

usePluginClass

@Nullable
public <T> Class<T> usePluginClass(String pluginType,
                                             String pluginName,
                                             String pluginId,
                                             PluginProperties pluginProperties,
                                             PluginSelector pluginSelector)

Specified by:

usePluginClass in interface PluginConfigurer

addStream

public void addStream(Stream stream)

Specified by:

addStream in interface DatasetConfigurer

addStream

public void addStream(String s)

Specified by:

addStream in interface DatasetConfigurer

addDatasetModule

public void addDatasetModule(String s,
                             Class<? extends DatasetModule> aClass)

Specified by:

addDatasetModule in interface DatasetConfigurer

addDatasetType

public void addDatasetType(Class<? extends Dataset> aClass)

Specified by:

addDatasetType in interface DatasetConfigurer

createDataset

public void createDataset(String s,
                          String s1,
                          DatasetProperties datasetProperties)

Specified by:

createDataset in interface DatasetConfigurer

createDataset

public void createDataset(String s,
                          String s1)

Specified by:

createDataset in interface DatasetConfigurer

createDataset

public void createDataset(String s,
                          Class<? extends Dataset> aClass,
                          DatasetProperties datasetProperties)

Specified by:

createDataset in interface DatasetConfigurer

createDataset

public void createDataset(String s,
                          Class<? extends Dataset> aClass)

Specified by:

createDataset in interface DatasetConfigurer