SparkSession¶

SparkSession is the entry point to Spark SQL.

Session UUID¶

sessionUUID: String

SparkSession generates a random UUID when created.

sessionUUID is used when:

• SparkConnectPlanner is requested to transformCachedLocalRelation
• SessionHolder is requested to serverSessionId
• SparkConnectArtifactStatusesHandler is requested to cacheExists
• SparkConnectSessionManager is requested to getIsolatedSession, getOrCreateIsolatedSession
• SparkSession is requested to addTag, sessionJobTag
• ArtifactManager is requested to many things
• ExecutionListenerBus is created (one per SparkSession) and requested to doPostEvent

sessionJobTag¶

sessionJobTag: String

sessionJobTag is the following text (with this sessionUUID):

spark-session-$sessionUUID

sessionJobTag is used when:

• SparkSession is requested to interruptAll
• SQLExecution is requested for the executionIdJobTag and to withSessionTagsApplied

interruptOperation¶

interruptOperation(
  operationId: String): Seq[String]

interruptOperation...FIXME

interruptAll¶

interruptAll(): Seq[String]

interruptAll doInterruptTag with this sessionJobTag and the following reason:

as part of cancellation of all jobs