Skip to content

SparkConnectStreamHandler

Creating Instance

SparkConnectStreamHandler takes the following to be created:

  • StreamObserver of ExecutePlanResponses

SparkConnectStreamHandler is created when:

Handling ExecutePlanRequest

handle(
  v: ExecutePlanRequest): Unit

handle...FIXME

handlePlan

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

handlePlan...FIXME