ExecuteHolder¶

Creating Instance¶

ExecuteHolder takes the following to be created:

• ExecutePlanRequest
• SessionHolder

ExecuteHolder is created when:

• SparkConnectExecutionManager is requested to create an ExecuteHolder

ExecuteThreadRunner¶

ExecuteHolder creates an ExecuteThreadRunner when created (with a reference to itself).

The ExecuteThreadRunner is used for the following:

• close
• interrupt
• isOrphan
• start

Start¶

start(): Unit

start requests this ExecuteThreadRunner to start.

start is used when:

• SparkConnectExecutionManager is requested to createExecuteHolderAndAttach

runGrpcResponseSender¶

runGrpcResponseSender(
  responseSender: ExecuteGrpcResponseSender[proto.ExecutePlanResponse]): Unit
runGrpcResponseSender(
  responseSender: ExecuteGrpcResponseSender[proto.ExecutePlanResponse],
  lastConsumedResponseId: String): Unit

runGrpcResponseSender...FIXME

runGrpcResponseSender is used when:

• SparkConnectExecutePlanHandler is requested to handle a ExecutePlanRequest
• SparkConnectReattachExecuteHandler is requested to handle a ReattachExecuteRequest