Struct ExecutorResourceRequests 

pub struct ExecutorResourceRequests { /* private fields */ }

Builder for executor resource requests.

Mirrors pyspark.resource.ExecutorResourceRequests. Allows specifying resources requested by executors, including memory, cores, and custom resources.

Implementations

impl ExecutorResourceRequests

pub fn new() -> ExecutorResourceRequests

Create a new empty ExecutorResourceRequests builder.

pub fn memory(self, memory_mb: i64) -> ExecutorResourceRequests

Set the memory requirement in MB.

pub fn off_heap_memory(self, memory_mb: i64) -> ExecutorResourceRequests

Set the off-heap memory requirement in MB.

pub fn cores(self, num_cores: i64) -> ExecutorResourceRequests

Set the number of cores.

pub fn resource( self, name: &str, amount: i64, discovery_script: Option<String>, vendor: Option<String>, ) -> ExecutorResourceRequests

Add a custom resource request.

Arguments

• name - The resource name (e.g., “gpu”, “fpga”)
• amount - The amount of the resource being requested
• discovery_script - Optional script to discover the resource on the executor
• vendor - Optional vendor name for the resource

Trait Implementations

impl Clone for ExecutorResourceRequests

fn clone(&self) -> ExecutorResourceRequests

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ExecutorResourceRequests

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

Formats the value using the given formatter.

impl Default for ExecutorResourceRequests

fn default() -> ExecutorResourceRequests

Returns the “default value” for a type.