ExecuteGrpcResponseSender¶
Creating Instance¶
ExecuteGrpcResponseSender
takes the following to be created:
- ExecuteHolder
-
StreamObserver[T]
ExecuteGrpcResponseSender
is created when:
SparkConnectExecutePlanHandler
is requested to handle a ExecutePlanRequestSparkConnectReattachExecuteHandler
is requested handle aReattachExecuteRequest
Run¶
run
...FIXME
run
is used when:
ExecuteHolder
is requested to runGrpcResponseSender
Execute¶
execute
...FIXME
enqueueProgressMessage¶
enqueueProgressMessage
...FIXME