co.cask.cdap.etl.spark.plugin

Class WrappedJavaSparkMain

java.lang.Object

co.cask.cdap.etl.spark.plugin.WrappedJavaSparkMain

All Implemented Interfaces:

JavaSparkMain, Serializable

public class WrappedJavaSparkMain
extends Object
implements JavaSparkMain

Wrapper around a JavaSparkMain that makes sure logging, classloading, and other pipeline capabilities are setup correctly.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
WrappedJavaSparkMain(JavaSparkMain delegate, Caller caller)

Method Summary

Modifier and Type	Method and Description
void	run(JavaSparkExecutionContext sec)

Methods inherited from class java.lang.Object

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

Constructor Detail

WrappedJavaSparkMain

public WrappedJavaSparkMain(JavaSparkMain delegate,
                            Caller caller)

Method Detail

run

public void run(JavaSparkExecutionContext sec)
         throws Exception

Specified by:

run in interface JavaSparkMain

Throws:

Exception