co.cask.cdap.etl.spark.batch

Class SparkBatchRuntimeContext

java.lang.Object

co.cask.cdap.etl.common.AbstractStageContext

co.cask.cdap.etl.common.AbstractTransformContext

co.cask.cdap.etl.spark.batch.SparkBatchRuntimeContext

All Implemented Interfaces:

DatasetContext, ServiceDiscoverer, BatchJoinerRuntimeContext, BatchRuntimeContext, LookupProvider, StageContext, TransformContext

public class SparkBatchRuntimeContext
extends AbstractTransformContext
implements BatchRuntimeContext, BatchJoinerRuntimeContext

Default implementation of BatchRuntimeContext for spark contexts.

Field Summary

Fields inherited from class co.cask.cdap.etl.common.AbstractStageContext

arguments

Constructor Summary

Constructors

Constructor and Description
SparkBatchRuntimeContext(PipelineRuntime pipelineRuntime, StageSpec stageSpec)

Method Summary

Modifier and Type	Method and Description
void	discardDataset(Dataset dataset)
<T extends Dataset> T	getDataset(String name)
<T extends Dataset> T	getDataset(String name, Map<String,String> arguments)
<T extends Dataset> T	getDataset(String namespace, String name)
<T extends Dataset> T	getDataset(String namespace, String name, Map<String,String> arguments)
Map<String,String>	getRuntimeArguments()
void	releaseDataset(Dataset dataset)

Methods inherited from class co.cask.cdap.etl.common.AbstractTransformContext

provide

Methods inherited from class co.cask.cdap.etl.common.AbstractStageContext

getArguments, getInputSchema, getInputSchemas, getLogicalStartTime, getMetrics, getNamespace, getOutputPortSchemas, getOutputSchema, getPipelineName, getPluginProperties, getPluginProperties, getServiceURL, getServiceURL, getStageName, loadPluginClass, newPluginInstance

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.etl.api.batch.BatchRuntimeContext

getLogicalStartTime

Methods inherited from interface co.cask.cdap.etl.api.StageContext

getArguments, getInputSchema, getInputSchemas, getMetrics, getNamespace, getOutputPortSchemas, getOutputSchema, getPipelineName, getPluginProperties, getPluginProperties, getStageName, loadPluginClass, newPluginInstance

Methods inherited from interface co.cask.cdap.api.ServiceDiscoverer

getServiceURL, getServiceURL

Methods inherited from interface co.cask.cdap.etl.api.LookupProvider

provide

Constructor Detail

SparkBatchRuntimeContext

public SparkBatchRuntimeContext(PipelineRuntime pipelineRuntime,
                                StageSpec stageSpec)

Method Detail

getRuntimeArguments

public Map<String,String> getRuntimeArguments()

Specified by:

getRuntimeArguments in interface BatchRuntimeContext

getDataset

public <T extends Dataset> T getDataset(String name)
                                 throws DatasetInstantiationException

Specified by:

getDataset in interface DatasetContext

Throws:

DatasetInstantiationException

getDataset

public <T extends Dataset> T getDataset(String namespace,
                                        String name)
                                 throws DatasetInstantiationException

Specified by:

getDataset in interface DatasetContext

Throws:

DatasetInstantiationException

getDataset

public <T extends Dataset> T getDataset(String name,
                                        Map<String,String> arguments)
                                 throws DatasetInstantiationException

Specified by:

getDataset in interface DatasetContext

Throws:

DatasetInstantiationException

getDataset

public <T extends Dataset> T getDataset(String namespace,
                                        String name,
                                        Map<String,String> arguments)
                                 throws DatasetInstantiationException

Specified by:

getDataset in interface DatasetContext

Throws:

DatasetInstantiationException

releaseDataset

public void releaseDataset(Dataset dataset)

Specified by:

releaseDataset in interface DatasetContext

discardDataset

public void discardDataset(Dataset dataset)

Specified by:

discardDataset in interface DatasetContext