object SparkSession extends SparkSessionCompanion with Serializable
- Source
- SparkSession.scala
- Alphabetic
- By Inheritance
- SparkSession
- Serializable
- SparkSessionCompanion
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- class Builder extends SparkSessionBuilder
- type Session = SparkSession
- Definition Classes
- SparkSession → SparkSessionCompanion
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- def active: Session
Returns the currently active SparkSession, otherwise the default one.
Returns the currently active SparkSession, otherwise the default one. If there is no default SparkSession, throws an exception.
- Definition Classes
- SparkSessionCompanion
- Since
2.4.0
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def builder(): Builder
Creates a SparkSessionBuilder for constructing a SparkSession.
Creates a SparkSessionBuilder for constructing a SparkSession.
- Definition Classes
- SparkSession → SparkSessionCompanion
- def clearActiveSession(): Unit
Clears the active SparkSession for current thread.
Clears the active SparkSession for current thread. Subsequent calls to getOrCreate will return the first created context instead of a thread-local override.
- Definition Classes
- SparkSessionCompanion
- Since
2.0.0
- def clearDefaultSession(): Unit
Clears the default SparkSession that is returned by the builder.
Clears the default SparkSession that is returned by the builder.
- Definition Classes
- SparkSessionCompanion
- Since
2.0.0
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def getActiveSession: Option[SparkSession]
Returns the active SparkSession for the current thread, returned by the builder.
Returns the active SparkSession for the current thread, returned by the builder.
- Definition Classes
- SparkSession → SparkSessionCompanion
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def getDefaultSession: Option[SparkSession]
Returns the default SparkSession that is returned by the builder.
Returns the default SparkSession that is returned by the builder.
- Definition Classes
- SparkSession → SparkSessionCompanion
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- def setActiveSession(session: SparkSession): Unit
Changes the SparkSession that will be returned in this thread and its children when SparkSession.getOrCreate() is called.
Changes the SparkSession that will be returned in this thread and its children when SparkSession.getOrCreate() is called. This can be used to ensure that a given thread receives a SparkSession with an isolated session, instead of the global (first created) context.
- Definition Classes
- SparkSession → SparkSessionCompanion
- def setDefaultAndActiveSession(session: Session): Unit
Set the (global) default SparkSession, and (thread-local) active SparkSession when they are not set yet, or they are not usable.
Set the (global) default SparkSession, and (thread-local) active SparkSession when they are not set yet, or they are not usable.
- Attributes
- protected
- Definition Classes
- SparkSessionCompanion
- def setDefaultSession(session: SparkSession): Unit
Sets the default SparkSession that is returned by the builder.
Sets the default SparkSession that is returned by the builder.
- Definition Classes
- SparkSession → SparkSessionCompanion
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- def tryCastToImplementation(session: SparkSession): Option[SparkSession]
- Attributes
- protected
- Definition Classes
- SparkSession → SparkSessionCompanion
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)