co.cask.cdap.etl.spark.function

Class PluginFunctionContext

java.lang.Object

co.cask.cdap.etl.spark.function.PluginFunctionContext

All Implemented Interfaces:

Serializable

public class PluginFunctionContext
extends Object
implements Serializable

Serializable collection of objects that can be used in Spark closures to instantiate plugins.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
PluginFunctionContext(StageSpec stageSpec, JavaSparkExecutionContext sec, Map<String,String> arguments, long logicalStartTime, StageStatisticsCollector collector)
PluginFunctionContext(StageSpec stageSpec, JavaSparkExecutionContext sec, StageStatisticsCollector collector)

Method Summary

Modifier and Type	Method and Description
SparkBatchRuntimeContext	createBatchRuntimeContext()
<T> T	createPlugin()
StageMetrics	createStageMetrics()
DataTracer	getDataTracer()
String	getStageName()
StageSpec	getStageSpec()
StageStatisticsCollector	getStageStatisticsCollector()

Methods inherited from class java.lang.Object

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

Constructor Detail

PluginFunctionContext

public PluginFunctionContext(StageSpec stageSpec,
                             JavaSparkExecutionContext sec,
                             StageStatisticsCollector collector)

PluginFunctionContext

public PluginFunctionContext(StageSpec stageSpec,
                             JavaSparkExecutionContext sec,
                             Map<String,String> arguments,
                             long logicalStartTime,
                             StageStatisticsCollector collector)

Method Detail

createPlugin

public <T> T createPlugin()
                   throws Exception

Throws:

Exception

getStageName

public String getStageName()

getStageSpec

public StageSpec getStageSpec()

createStageMetrics

public StageMetrics createStageMetrics()

getStageStatisticsCollector

public StageStatisticsCollector getStageStatisticsCollector()

createBatchRuntimeContext

public SparkBatchRuntimeContext createBatchRuntimeContext()

getDataTracer

public DataTracer getDataTracer()