BaseSessionStateBuilder — Base for Builders of SessionState

Note
 BaseSessionStateBuilder is an experimental and unstable API. You’ve been warned!.

BaseSessionStateBuilder is created when SparkSession is requested for a SessionState (and also when newBuilder is called).

val spark: SparkSession = ...
scala> spark.sessionState
res0: org.apache.spark.sql.internal.SessionState = org.apache.spark.sql.internal.SessionState@5feb8e9a
Note
 SessionStateBuilder and HiveSessionStateBuilder are concrete BaseSessionStateBuilder.
Table 1. BaseSessionStateBuilder’s Properties (in alphabetical order)
Name Description

analyzer

catalog

conf

createClone

createQueryExecution

experimentalMethods

functionRegistry

FunctionRegistry

CAUTION: FIXME Where is this used?

listenerManager

optimizer

planner

resourceLoader

sqlParser

streamingQueryManager

udfRegistration
Note

BaseSessionStateBuilder defines a type alias NewBuilder for a function to create a BaseSessionStateBuilder.

type NewBuilder = (SparkSession, Option[SessionState]) => BaseSessionStateBuilder

BaseSessionStateBuilder Contract

abstract class BaseSessionStateBuilder {
  def newBuilder: NewBuilder
}
Table 2. BaseSessionStateBuilder Contract (in alphabetical order)
Method Description

newBuilder

Function to create a BaseSessionStateBuilder

Creating BaseSessionStateBuilder Instance

BaseSessionStateBuilder takes the following when created:

Building SessionState — build Method

build(): SessionState

build creates a SessionState (based on the SharedState of the input SparkSession and properties).

results matching ""

    No results matching ""