co.cask.cdap.etl.spark.batch

Class BasicSparkPluginContext

java.lang.Object

co.cask.cdap.etl.common.AbstractStageContext

co.cask.cdap.etl.common.AbstractTransformContext

co.cask.cdap.etl.batch.AbstractBatchContext

co.cask.cdap.etl.spark.batch.BasicSparkPluginContext

All Implemented Interfaces:

DatasetContext, ServiceDiscoverer, BatchContext, SparkPluginContext, LookupProvider, StageContext, TransformContext

public class BasicSparkPluginContext
extends AbstractBatchContext
implements SparkPluginContext

Implementation of SparkPluginContext that delegates to a SparkContext.

Field Summary

Fields inherited from class co.cask.cdap.etl.batch.AbstractBatchContext

admin

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

arguments

Constructor Summary

Constructors

Constructor and Description
BasicSparkPluginContext(SparkClientContext sparkContext, PipelineRuntime pipelineRuntime, StageSpec stageSpec, DatasetContext datasetContext, Admin admin)

Method Summary

Modifier and Type	Method and Description
void	setSparkConf(org.apache.spark.SparkConf sparkConf)

Methods inherited from class co.cask.cdap.etl.batch.AbstractBatchContext

createDataset, datasetExists, discardDataset, getDataset, getDataset, getDataset, getDataset, getRuntimeArguments, releaseDataset, setRuntimeArgument

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

provide

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

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.BatchContext

createDataset, datasetExists, getArguments, getRuntimeArguments, setRuntimeArgument

Methods inherited from interface co.cask.cdap.api.data.DatasetContext

discardDataset, getDataset, getDataset, getDataset, getDataset, releaseDataset

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

getInputSchema, getInputSchemas, getLogicalStartTime, 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

BasicSparkPluginContext

public BasicSparkPluginContext(@Nullable
                               SparkClientContext sparkContext,
                               PipelineRuntime pipelineRuntime,
                               StageSpec stageSpec,
                               DatasetContext datasetContext,
                               Admin admin)

Method Detail

setSparkConf

public void setSparkConf(org.apache.spark.SparkConf sparkConf)

Specified by:

setSparkConf in interface SparkPluginContext