pub struct RunTimeConfig { /* private fields */ }
Implementations§
Source§impl RunTimeConfig
User-facing configuration API, accessible through SparkSession.conf.
impl RunTimeConfig
User-facing configuration API, accessible through SparkSession.conf.
Options set here are automatically propagated to the Hadoop configuration during I/O.
§Example
spark
.conf()
.set("spark.sql.shuffle.partitions", "42")
.await?;
pub fn new( client: &SparkConnectClient<InterceptedService<Channel, MetadataInterceptor>>, ) -> RunTimeConfig
Sourcepub async fn set(&mut self, key: &str, value: &str) -> Result<(), SparkError>
pub async fn set(&mut self, key: &str, value: &str) -> Result<(), SparkError>
Sets the given Spark runtime configuration property.
Sourcepub async fn unset(&mut self, key: &str) -> Result<(), SparkError>
pub async fn unset(&mut self, key: &str) -> Result<(), SparkError>
Resets the configuration property for the given key.
Sourcepub async fn get(
&mut self,
key: &str,
default: Option<&str>,
) -> Result<String, SparkError>
pub async fn get( &mut self, key: &str, default: Option<&str>, ) -> Result<String, SparkError>
Indicates whether the configuration property with the given key is modifiable in the current session.
Sourcepub async fn is_modifable(&mut self, key: &str) -> Result<bool, SparkError>
pub async fn is_modifable(&mut self, key: &str) -> Result<bool, SparkError>
Indicates whether the configuration property with the given key is modifiable in the current session.
Auto Trait Implementations§
impl Freeze for RunTimeConfig
impl !RefUnwindSafe for RunTimeConfig
impl Send for RunTimeConfig
impl Sync for RunTimeConfig
impl Unpin for RunTimeConfig
impl !UnwindSafe for RunTimeConfig
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T
in a tonic::Request