ExecuteGrpcResponseSender¶

Creating Instance¶

ExecuteGrpcResponseSender takes the following to be created:

• ExecuteHolder
• StreamObserver[T]

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:

• ExecuteHolder is requested to runGrpcResponseSender

Execute¶

execute(
  lastConsumedStreamIndex: Long): Unit

execute...FIXME

enqueueProgressMessage¶

enqueueProgressMessage(
  force: Boolean = false): Unit

enqueueProgressMessage...FIXME