co.cask.cdap.etl.mock.transform

Class MockTransformContext

java.lang.Object

co.cask.cdap.etl.mock.transform.MockTransformContext

All Implemented Interfaces:

ServiceDiscoverer, LookupProvider, StageContext, TransformContext

public class MockTransformContext
extends Object
implements TransformContext

Mock context for unit tests

Constructor Summary

Constructors

Constructor and Description
MockTransformContext()
MockTransformContext(String stageName)
MockTransformContext(String stageName, Map<String,String> args)
MockTransformContext(String stageName, Map<String,String> args, LookupProvider lookup)

Method Summary

Modifier and Type	Method and Description
Arguments	getArguments()
co.cask.cdap.api.data.schema.Schema	getInputSchema()
Map<String,co.cask.cdap.api.data.schema.Schema>	getInputSchemas()
long	getLogicalStartTime()
StageMetrics	getMetrics()
MockStageMetrics	getMockMetrics()
String	getNamespace()
Map<String,co.cask.cdap.api.data.schema.Schema>	getOutputPortSchemas()
co.cask.cdap.api.data.schema.Schema	getOutputSchema()
String	getPipelineName()
PluginProperties	getPluginProperties()
PluginProperties	getPluginProperties(String pluginId)
URL	getServiceURL(String serviceId)
URL	getServiceURL(String applicationId, String serviceId)
String	getStageName()
<T> Class<T>	loadPluginClass(String pluginId)
<T> T	newPluginInstance(String pluginId)
<T> Lookup<T>	provide(String table, Map<String,String> arguments)

Methods inherited from class java.lang.Object

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

Constructor Detail

MockTransformContext

public MockTransformContext()

MockTransformContext

public MockTransformContext(String stageName)

MockTransformContext

public MockTransformContext(String stageName,
                            Map<String,String> args)

MockTransformContext

public MockTransformContext(String stageName,
                            Map<String,String> args,
                            LookupProvider lookup)

Method Detail

getPluginProperties

public PluginProperties getPluginProperties()

Specified by:

getPluginProperties in interface StageContext

getPluginProperties

public PluginProperties getPluginProperties(String pluginId)

Specified by:

getPluginProperties in interface StageContext

getMetrics

public StageMetrics getMetrics()

Specified by:

getMetrics in interface StageContext

getMockMetrics

public MockStageMetrics getMockMetrics()

getStageName

public String getStageName()

Specified by:

getStageName in interface StageContext

getNamespace

public String getNamespace()

Specified by:

getNamespace in interface StageContext

getPipelineName

public String getPipelineName()

Specified by:

getPipelineName in interface StageContext

getLogicalStartTime

public long getLogicalStartTime()

Specified by:

getLogicalStartTime in interface StageContext

newPluginInstance

public <T> T newPluginInstance(String pluginId)
                        throws InstantiationException

Specified by:

newPluginInstance in interface StageContext

Throws:

InstantiationException

getInputSchema

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

Specified by:

getInputSchema in interface StageContext

getInputSchemas

public Map<String,co.cask.cdap.api.data.schema.Schema> getInputSchemas()

Specified by:

getInputSchemas in interface StageContext

getOutputSchema

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

Specified by:

getOutputSchema in interface StageContext

getOutputPortSchemas

public Map<String,co.cask.cdap.api.data.schema.Schema> getOutputPortSchemas()

Specified by:

getOutputPortSchemas in interface StageContext

getArguments

public Arguments getArguments()

Specified by:

getArguments in interface StageContext

loadPluginClass

public <T> Class<T> loadPluginClass(String pluginId)

Specified by:

loadPluginClass in interface StageContext

provide

public <T> Lookup<T> provide(String table,
                             Map<String,String> arguments)

Specified by:

provide in interface LookupProvider

getServiceURL

@Nullable
public URL getServiceURL(String applicationId,
                                   String serviceId)

Specified by:

getServiceURL in interface ServiceDiscoverer

getServiceURL

@Nullable
public URL getServiceURL(String serviceId)

Specified by:

getServiceURL in interface ServiceDiscoverer