Skip to content

ExecuteGrpcResponseSender

Creating Instance

ExecuteGrpcResponseSender takes the following to be created:

ExecuteGrpcResponseSender is created when:

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

Run

run(
  lastConsumedStreamIndex: Long): Unit

run...FIXME


run is used when:

Execute

execute(
  lastConsumedStreamIndex: Long): Unit

execute...FIXME

enqueueProgressMessage

enqueueProgressMessage(
  force: Boolean = false): Unit

enqueueProgressMessage...FIXME