co.cask.cdap.etl.spark

Class SparkPipelineRuntime

java.lang.Object

co.cask.cdap.etl.common.PipelineRuntime

co.cask.cdap.etl.spark.SparkPipelineRuntime

public class SparkPipelineRuntime
extends PipelineRuntime

PipelineRuntime that can be created using Spark contexts.

Constructor Summary

Constructors

Constructor and Description
SparkPipelineRuntime(JavaSparkExecutionContext sec)
SparkPipelineRuntime(JavaSparkExecutionContext sec, long batchTime)
SparkPipelineRuntime(SparkClientContext context)

Method Summary

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

getArguments, getLogicalStartTime, getMetrics, getNamespace, getPipelineName, getPluginContext, getServiceDiscoverer

Methods inherited from class java.lang.Object

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

Constructor Detail

SparkPipelineRuntime

public SparkPipelineRuntime(SparkClientContext context)

SparkPipelineRuntime

public SparkPipelineRuntime(JavaSparkExecutionContext sec)

SparkPipelineRuntime

public SparkPipelineRuntime(JavaSparkExecutionContext sec,
                            long batchTime)