org.apache.spark

Class SparkEnv

Object

org.apache.spark.SparkEnv

public class SparkEnv
extends Object

:: DeveloperApi :: Holds all the runtime environment objects for a running Spark instance (either master or worker), including the serializer, RpcEnv, block manager, map output tracker, etc. Currently Spark code finds the SparkEnv through a global variable, so all the threads can access the same SparkEnv. It can be accessed by SparkEnv.get (e.g. after creating a SparkContext).

NOTE: This is not intended for external use. This is exposed for Shark and may be made private in a future release.

Constructor Summary

Constructors

Constructor and Description

SparkEnv(String executorId, org.apache.spark.rpc.RpcEnv rpcEnv, Serializer serializer, Serializer closureSerializer, org.apache.spark.serializer.SerializerManager serializerManager, org.apache.spark.MapOutputTracker mapOutputTracker, org.apache.spark.shuffle.ShuffleManager shuffleManager, org.apache.spark.broadcast.BroadcastManager broadcastManager, org.apache.spark.storage.BlockManager blockManager, org.apache.spark.SecurityManager securityManager, org.apache.spark.metrics.MetricsSystem metricsSystem, org.apache.spark.memory.MemoryManager memoryManager, org.apache.spark.scheduler.OutputCommitCoordinator outputCommitCoordinator, SparkConf conf)

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.spark.storage.BlockManager	blockManager()
org.apache.spark.broadcast.BroadcastManager	broadcastManager()
Serializer	closureSerializer()
SparkConf	conf()
String	executorId()
static SparkEnv	get() Returns the SparkEnv.
org.apache.spark.MapOutputTracker	mapOutputTracker()
org.apache.spark.memory.MemoryManager	memoryManager()
org.apache.spark.metrics.MetricsSystem	metricsSystem()
org.apache.spark.scheduler.OutputCommitCoordinator	outputCommitCoordinator()
org.apache.spark.SecurityManager	securityManager()
Serializer	serializer()
org.apache.spark.serializer.SerializerManager	serializerManager()
static void	set(SparkEnv e)
org.apache.spark.shuffle.ShuffleManager	shuffleManager()

Methods inherited from class Object

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

Constructor Detail

SparkEnv

public SparkEnv(String executorId,
        org.apache.spark.rpc.RpcEnv rpcEnv,
        Serializer serializer,
        Serializer closureSerializer,
        org.apache.spark.serializer.SerializerManager serializerManager,
        org.apache.spark.MapOutputTracker mapOutputTracker,
        org.apache.spark.shuffle.ShuffleManager shuffleManager,
        org.apache.spark.broadcast.BroadcastManager broadcastManager,
        org.apache.spark.storage.BlockManager blockManager,
        org.apache.spark.SecurityManager securityManager,
        org.apache.spark.metrics.MetricsSystem metricsSystem,
        org.apache.spark.memory.MemoryManager memoryManager,
        org.apache.spark.scheduler.OutputCommitCoordinator outputCommitCoordinator,
        SparkConf conf)

Method Detail

set

public static void set(SparkEnv e)

get

public static SparkEnv get()

Returns the SparkEnv.

Returns:

(undocumented)

executorId

public String executorId()

serializer

public Serializer serializer()

closureSerializer

public Serializer closureSerializer()

serializerManager

public org.apache.spark.serializer.SerializerManager serializerManager()

mapOutputTracker

public org.apache.spark.MapOutputTracker mapOutputTracker()

shuffleManager

public org.apache.spark.shuffle.ShuffleManager shuffleManager()

broadcastManager

public org.apache.spark.broadcast.BroadcastManager broadcastManager()

blockManager

public org.apache.spark.storage.BlockManager blockManager()

securityManager

public org.apache.spark.SecurityManager securityManager()

metricsSystem

public org.apache.spark.metrics.MetricsSystem metricsSystem()

memoryManager

public org.apache.spark.memory.MemoryManager memoryManager()

outputCommitCoordinator

public org.apache.spark.scheduler.OutputCommitCoordinator outputCommitCoordinator()

conf

public SparkConf conf()