Struct SparkSessionBuilder 

pub struct SparkSessionBuilder { /* private fields */ }

Builder for creating SparkSession instances.

Configures a connection to a Spark Connect endpoint following the URL format defined by Apache Spark’s client connection spec.

Example

use spark_connect::SparkSessionBuilder;

let session = SparkSessionBuilder::new("sc://localhost:15002")
    .build()
    .await
    .unwrap();

println!("Session ID: {}", session.session_id());

Implementations

impl SparkSessionBuilder

pub fn new(connection: &str) -> Self

Creates a new builder from a Spark Connect connection string.

The connection string must follow the format: sc://<host>:<port>/;key1=value1;key2=value2;...

pub async fn build(&self) -> Result<SparkSession, SparkError>

Establishes a connection and returns a ready-to-use SparkSession.

This method performs:

• gRPC channel setup;
• Metadata interceptor attachment;
• SparkClient initialization.

Trait Implementations

impl Clone for SparkSessionBuilder

fn clone(&self) -> SparkSessionBuilder

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SparkSessionBuilder

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.