Struct ArrowConnector

pub struct ArrowConnector { /* private fields */ }

Available on crate feature connector-arrow only.

A connector for Apache Arrow.

Implementations

impl ArrowConnector

pub fn new() -> Self

Creates a new instance with the default configuration.

pub fn with_config(config: &Table) -> Self

Creates a new instance with the configuration.

pub async fn bind_system_variables(&mut self, variables: &Table)

Binds system variables.

pub async fn bind_user_defined_variables(&mut self, variables: &Map)

Binds user defined variables.

pub async fn try_get_session_context(&self) -> Result<&SessionContext, Error>

Attempts to get the session context.

pub async fn read_avro_records( &self, records: &[Record], ) -> Result<DataFrame, Error>

Attempts to create a DateFrame from reading Avro records.

Trait Implementations

impl Connector for ArrowConnector

fn try_new_data_source(config: &Table) -> Result<DataSource, Error>

Constructs a new data source with the configuration, returning an error if it fails.

async fn execute( &self, query: &str, params: Option<&Map>, ) -> Result<Option<u64>, Error>

Executes the query and returns the total number of rows affected.

async fn query( &self, query: &str, params: Option<&Map>, ) -> Result<Vec<Record>, Error>

Executes the query and parses it as Vec<Record>.

async fn query_as<T: DeserializeOwned>( &self, query: &str, params: Option<&Map>, ) -> Result<Vec<T>, Error>

Executes the query and parses it as Vec<T>.

async fn query_one( &self, query: &str, params: Option<&Map>, ) -> Result<Option<Record>, Error>

Executes the query and parses it as a Record.

async fn query_one_as<T: DeserializeOwned>( &self, query: &str, params: Option<&Map>, ) -> Result<Option<T>, Error>

Executes the query and parses it as an instance of type T.

impl Default for ArrowConnector

fn default() -> Self

Returns the “default value” for a type.