CustomSparkConnectBlockingStub¶

Creating Instance¶

CustomSparkConnectBlockingStub takes the following to be created:

• ManagedChannel
• SparkConnectStubState

CustomSparkConnectBlockingStub is created along with SparkConnectClient.

executePlanReattachable¶

executePlanReattachable(
  request: ExecutePlanRequest): CloseableIterator[ExecutePlanResponse]

executePlanReattachable...FIXME

executePlanReattachable is used when:

• SparkConnectClient is requested to execute a plan (with useReattachableExecute enabled)