class SharedSingleton[T] extends Serializable

Holds a variable shared among all workers that behaves like a local singleton. Useful to use non-serializable objects in Spark closures that maintain state across tasks.

Linear Supertypes
Serializable, Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. SharedSingleton
  2. Serializable
  3. Serializable
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new SharedSingleton(constructor: ⇒ T)(implicit arg0: ClassTag[T])

Value Members

  1. def get: T
  2. val singletonUUID: String