Skip to content

SQLExecution

executionIdJobTag

executionIdJobTag(
  session: SparkSession,
  id: Long)

executionIdJobTag is the following text (with the sessionJobTag of the given SparkSession):

[sessionJobTag]-execution-root-id-[id]

executionIdJobTag is used when:

withNewExecutionId

withNewExecutionId[T](
  queryExecution: QueryExecution,
  name: Option[String] = None)(
  body: => T): T

withNewExecutionId withNewExecutionId0 with the given QueryExecution, the optional name and the body (as a Right value).

withNewExecutionIdOnError

withNewExecutionIdOnError(
  queryExecution: QueryExecution,
  name: Option[String] = None)(
  t: Throwable): Unit

withNewExecutionIdOnError withNewExecutionId0 with the given QueryExecution, the optional name and the Throwable (as a Left value).

withNewExecutionIdOnError is used when:

  • QueryExecution is requested to assertAnalyzed

withExecutionId

withExecutionId[T](
  sparkSession: SparkSession,
  executionId: String)(
  body: => T): T

withExecutionId...FIXME

withExecutionId is used when:

  • SubqueryExec physical operator is requested for the relationFuture
  • SubqueryBroadcastExec physical operator is requested for the relationFuture

withThreadLocalCaptured

withThreadLocalCaptured[T](
  sparkSession: SparkSession,
  exec: ExecutorService)(
  body: => T): Future[T]

withThreadLocalCaptured...FIXME

withThreadLocalCaptured is used when:

  • BroadcastExchangeExec physical operator is requested for the relationFuture
  • BroadcastExchangeLike physical operator is requested for the triggerFuture
  • SubqueryExec physical operator is requested for the relationFuture
  • SubqueryBroadcastExec physical operator is requested for the relationFuture
  • ShuffleExchangeLike physical operator is requested for the triggerFuture

withNewExecutionId0

withNewExecutionId0[T](
  queryExecution: QueryExecution,
  name: Option[String] = None)(
  body: Either[Throwable, () => T]): T

withNewExecutionId0...FIXME

withNewExecutionId0 is used when:

withSessionTagsApplied

withSessionTagsApplied[T](
  sparkSession: SparkSession)(
  block: => T): T

withSessionTagsApplied...FIXME

withSessionTagsApplied is used when: