sjrusso8

use spark_connect_rs::{SparkSession, SparkSessionBuilder};

use spark_connect_rs::dataframe::SaveMode;
use spark_connect_rs::functions as F;
use spark_connect_rs::types::*;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let spark: SparkSession = SparkSessionBuilder::remote("sc://127.0.0.1:15002/")
        .build()

sjrusso8

use spark_connect_rs;

use spark_connect_rs::dataframe::SaveMode;
use spark_connect_rs::{SparkSession, SparkSessionBuilder};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let spark: SparkSession =
        SparkSessionBuilder::remote("sc://127.0.0.1:15002/;user_id=example_rs")
            .build()

sjrusso8

sjrusso8

sjrusso8

sjrusso8

sjrusso8

sjrusso8

# Response to two code questions

# These functions can be further improved by type checking the input values with `isinstance`