Struct SparkConnectClient

pub struct SparkConnectClient<T> { /* private fields */ }

Client wrapper to handle submitting requests and handling responses from the SparkConnectServiceClient

Implementations

impl<T> SparkConnectClient<T>

where T: GrpcService<BoxBody>, T::Error: Into<StdError>, T::ResponseBody: Body<Data = Bytes> + Send + 'static, <T::ResponseBody as Body>::Error: Into<StdError> + Send,

pub fn new( stub: Arc<RwLock<SparkConnectServiceClient<T>>>, builder: ChannelBuilder, ) -> Self

pub fn session_id(&self) -> String

Session ID

pub fn set_reattachable_execute( &mut self, setting: bool, ) -> Result<(), SparkError>

Change the reattachable execute value

pub fn execute_plan_request_with_metadata(&self) -> ExecutePlanRequest

pub fn analyze_plan_request_with_metadata(&self) -> AnalyzePlanRequest

pub async fn execute_and_fetch( &mut self, req: ExecutePlanRequest, ) -> Result<(), SparkError>

pub async fn analyze( &mut self, analyze: Analyze, ) -> Result<&mut Self, SparkError>

pub fn add_tag(&mut self, tag: &str) -> Result<(), SparkError>

pub fn remove_tag(&mut self, tag: &str) -> Result<(), SparkError>

pub fn get_tags(&self) -> &Vec<String>

pub fn clear_tags(&mut self)

pub async fn config_request( &self, operation: Operation, ) -> Result<ConfigResponse, SparkError>

pub async fn interrupt_request( &self, interrupt_type: InterruptType, id_or_tag: Option<String>, ) -> Result<InterruptResponse, SparkError>

pub async fn execute_command(&mut self, plan: Plan) -> Result<(), SparkError>

pub async fn to_arrow(&mut self, plan: Plan) -> Result<RecordBatch, SparkError>

pub fn schema(&self) -> Result<DataType, SparkError>

pub fn explain(&self) -> Result<String, SparkError>

pub fn tree_string(&self) -> Result<String, SparkError>

pub fn is_local(&self) -> Result<bool, SparkError>

pub fn is_streaming(&self) -> Result<bool, SparkError>

pub fn input_files(&self) -> Result<Vec<String>, SparkError>

pub fn spark_version(&mut self) -> Result<String, SparkError>

pub fn ddl_parse(&self) -> Result<DataType, SparkError>

pub fn same_semantics(&self) -> Result<bool, SparkError>

pub fn semantic_hash(&self) -> Result<i32, SparkError>

pub fn get_storage_level(&self) -> Result<StorageLevel, SparkError>

Trait Implementations

impl<T: Clone> Clone for SparkConnectClient<T>

fn clone(&self) -> SparkConnectClient<T>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for SparkConnectClient<T>

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

Formats the value using the given formatter.