Struct RuntimeConf 

pub struct RuntimeConf { /* private fields */ }

Runtime configuration for a Spark session.

Allows getting and setting runtime configuration parameters on the Spark server. Mirrors pyspark.sql.conf.RuntimeConfig.

Implementations

impl RuntimeConf

pub fn set(&self, key: &str, value: &str) -> Result<()>

Set a configuration key-value pair.

Converts boolean and integer values to strings as required by the server.

Arguments

• key - The configuration key (e.g., “spark.sql.shuffle.partitions”)
• value - The configuration value as a string, integer, or boolean

Example

conf.set("spark.sql.shuffle.partitions", "200")?;
conf.set("spark.sql.adaptive.enabled", true)?;
conf.set("spark.sql.maxMetadataStringLength", 100)?;

pub fn get(&self, key: &str) -> Result<Option<String>>

Get a configuration value by key.

Returns Ok(None) if the key does not exist on the server.

Arguments

• key - The configuration key to retrieve

Example

let value = conf.get("spark.sql.shuffle.partitions")?;
println!("Shuffle partitions: {:?}", value);

pub fn get_with_default( &self, key: &str, default: Option<&str>, ) -> Result<Option<String>>

Get a configuration value, returning default when the key is unset — instead of erroring as get does for an unknown key. Uses the server’s GetWithDefault operation, mirroring RuntimeConfig.get(key, default).

pub fn get_all(&self) -> Result<HashMap<String, String>>

Get all configuration values as a HashMap.

Example

let all_configs = conf.get_all()?;
for (key, value) in all_configs.iter() {
    println!("{}: {}", key, value);
}

pub fn unset(&self, key: &str) -> Result<()>

Unset a configuration key (reset to default).

Arguments

• key - The configuration key to unset

Example

conf.unset("spark.sql.shuffle.partitions")?;

pub fn is_modifiable(&self, key: &str) -> Result<bool>

Check if a configuration key is modifiable.

Returns true if the configuration can be changed at runtime, false if it’s read-only or cannot be modified.

Arguments

• key - The configuration key to check

Example

if conf.is_modifiable("spark.sql.shuffle.partitions")? {
    println!("This config can be modified");
}

Trait Implementations

impl Clone for RuntimeConf

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.