Package org.apache.wayang.spark.execution

Class SparkContextReference

java.lang.Object

org.apache.wayang.core.util.AbstractReferenceCountable

org.apache.wayang.core.platform.ExecutionResourceTemplate

org.apache.wayang.spark.execution.SparkContextReference

All Implemented Interfaces:

ExecutionResource, ReferenceCountable

public class SparkContextReference
extends ExecutionResourceTemplate

Wraps and manages a JavaSparkContext to avoid steady re-creation.

Constructor Summary

Constructors

Constructor	Description
SparkContextReference(CrossPlatformExecutor crossPlatformExecutor, org.apache.spark.api.java.JavaSparkContext sparkContext)	Creates a new instance.

Method Summary

Modifier and Type	Method	Description
protected void	doDispose()	Performs the actual disposing work of this instance.
org.apache.spark.api.java.JavaSparkContext	get()	Provides the JavaSparkContext.

Methods inherited from class org.apache.wayang.core.platform.ExecutionResourceTemplate

dispose, disposeUnreferenced

Methods inherited from class org.apache.wayang.core.util.AbstractReferenceCountable

disposeIfUnreferenced, getNumReferences, isDisposed, noteDiscardedReference, noteObtainedReference

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.wayang.core.util.ReferenceCountable

disposeIfUnreferenced, getNumReferences, isDisposed, noteDiscardedReference, noteObtainedReference

Constructor Details

SparkContextReference

public SparkContextReference(CrossPlatformExecutor crossPlatformExecutor,
 org.apache.spark.api.java.JavaSparkContext sparkContext)

Creates a new instance.

Parameters:

sparkContext - the JavaSparkContext to be wrapped

Method Details

doDispose

protected void doDispose()
                  throws Throwable

Description copied from class: ExecutionResourceTemplate

Performs the actual disposing work of this instance.

Specified by:

doDispose in class ExecutionResourceTemplate

Throws:

Throwable - in case anything goes wrong

get

public org.apache.spark.api.java.JavaSparkContext get()

Provides the JavaSparkContext. This instance must not be disposed, yet.

Returns:

the wrapped JavaSparkContext