ExecuteHolder¶

Creating Instance¶

ExecuteHolder takes the following to be created:

• ExecutePlanRequest
• SessionHolder

ExecuteHolder is created when:

• SparkConnectExecutionManager is requested to create an ExecuteHolder

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