co.cask.cdap.etl.mock.realtime

Class MockRealtimeContext

java.lang.Object

co.cask.cdap.etl.mock.realtime.MockRealtimeContext

All Implemented Interfaces:

LookupProvider, RealtimeContext, StageContext, TransformContext

public class MockRealtimeContext
extends Object
implements RealtimeContext

Mock RealtimeContext for tests.

Constructor Summary

Constructors

Constructor and Description
MockRealtimeContext()
MockRealtimeContext(Map<String,String> properties)

Method Summary

Methods

Modifier and Type	Method and Description
co.cask.cdap.api.data.schema.Schema	getInputSchema()
Map<String,co.cask.cdap.api.data.schema.Schema>	getInputSchemas()
int	getInstanceCount()
int	getInstanceId()
StageMetrics	getMetrics()
co.cask.cdap.api.data.schema.Schema	getOutputSchema()
PluginProperties	getPluginProperties()
PluginProperties	getPluginProperties(String pluginId)
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

MockRealtimeContext

public MockRealtimeContext(Map<String,String> properties)

MockRealtimeContext

public MockRealtimeContext()

Method Detail

getPluginProperties

public PluginProperties getPluginProperties()

Specified by:

getPluginProperties in interface StageContext

getMetrics

public StageMetrics getMetrics()

Specified by:

getMetrics in interface StageContext

getStageName

public String getStageName()

Specified by:

getStageName in interface StageContext

getInstanceId

public int getInstanceId()

Specified by:

getInstanceId in interface RealtimeContext

getInstanceCount

public int getInstanceCount()

Specified by:

getInstanceCount in interface RealtimeContext

getPluginProperties

public PluginProperties getPluginProperties(String pluginId)

Specified by:

getPluginProperties in interface StageContext

loadPluginClass

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

Specified by:

loadPluginClass 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

provide

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

Specified by:

provide in interface LookupProvider