SparkConnectStreamHandler¶

Creating Instance¶

SparkConnectStreamHandler takes the following to be created:

• StreamObserver of ExecutePlanResponses

SparkConnectStreamHandler is created when:

• SparkConnectService is requested to handle executePlan request

Handling ExecutePlanRequest¶

handle(
  v: ExecutePlanRequest): Unit

handle...FIXME

handlePlan¶

handlePlan(
  session: SparkSession,
  request: ExecutePlanRequest): Unit

handlePlan...FIXME