co.cask.cdap.etl.spark.plugin

Class SparkPipelinePluginContext

java.lang.Object

co.cask.cdap.etl.common.plugin.PipelinePluginContext

co.cask.cdap.etl.spark.plugin.SparkPipelinePluginContext

All Implemented Interfaces:

PluginContext

public class SparkPipelinePluginContext
extends PipelinePluginContext

Wraps spark specific plugin types.

Constructor Summary

Constructors

Constructor and Description
SparkPipelinePluginContext(PluginContext delegate, Metrics metrics, boolean stageLoggingEnabled, boolean processTimingEnabled)

Method Summary

Modifier and Type	Method and Description
protected Object	wrapUnknownPlugin(String pluginId, Object plugin, Caller caller)

Methods inherited from class co.cask.cdap.etl.common.plugin.PipelinePluginContext

getCaller, getPluginProperties, getPluginProperties, loadPluginClass, newPluginInstance, newPluginInstance

Methods inherited from class java.lang.Object

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

Constructor Detail

SparkPipelinePluginContext

public SparkPipelinePluginContext(PluginContext delegate,
                                  Metrics metrics,
                                  boolean stageLoggingEnabled,
                                  boolean processTimingEnabled)

Method Detail

wrapUnknownPlugin

protected Object wrapUnknownPlugin(String pluginId,
                                   Object plugin,
                                   Caller caller)

Overrides:

wrapUnknownPlugin in class PipelinePluginContext