Struct spark_connect_rs::client::SparkConnectClient

pub struct SparkConnectClient<T> {
    pub handler: ResponseHandler,
    pub analyzer: AnalyzeHandler,
    /* private fields */
}

Fields

handler: ResponseHandler

analyzer: AnalyzeHandler

Implementations

impl<T> SparkConnectClient<T>

where T: GrpcService<UnsyncBoxBody<Bytes, Status>>, <T as GrpcService<UnsyncBoxBody<Bytes, Status>>>::Error: Into<Box<dyn Error + Sync + Send>>, <T as GrpcService<UnsyncBoxBody<Bytes, Status>>>::ResponseBody: Body<Data = Bytes> + Send + 'static, <<T as GrpcService<UnsyncBoxBody<Bytes, Status>>>::ResponseBody as Body>::Error: Into<Box<dyn Error + Sync + Send>> + Send,

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

pub fn session_id(&self) -> String

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

Trait Implementations

impl<T> Clone for SparkConnectClient<T>

where T: Clone,

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 for SparkConnectClient<T>

where T: Debug,

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

Formats the value using the given formatter.