Trait edm_core::connector::DataFrameExecutor

pub trait DataFrameExecutor {
    // Required methods
    async fn execute(self) -> Result<Option<u64>, Error>;
    async fn query(self) -> Result<Vec<Record>, Error>;
    async fn query_as<T: DeserializeOwned>(self) -> Result<Vec<T>, Error>;
    async fn query_one(self) -> Result<Option<Record>, Error>;
    async fn query_one_as<T: DeserializeOwned>(self) -> Result<Option<T>, Error>;
    async fn output(self) -> Result<String, Error>;
}

Available on crate features connector-arrow and connector only.

Executor trait for DataFrame.

Required Methods

async fn execute(self) -> Result<Option<u64>, Error>

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

async fn query(self) -> Result<Vec<Record>, Error>

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

async fn query_as<T: DeserializeOwned>(self) -> Result<Vec<T>, Error>

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

async fn query_one(self) -> Result<Option<Record>, Error>

Executes the DataFrame and parses it as a Record.

async fn query_one_as<T: DeserializeOwned>(self) -> Result<Option<T>, Error>

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

async fn output(self) -> Result<String, Error>

Executes the DataFrame and creates a visual representation of record batches.

Object Safety

This trait is not object safe.

Implementations on Foreign Types

impl DataFrameExecutor for DataFrame

async fn execute(self) -> Result<Option<u64>, Error>

async fn query(self) -> Result<Vec<Record>, Error>

async fn query_as<T: DeserializeOwned>(self) -> Result<Vec<T>, Error>

async fn query_one(self) -> Result<Option<Record>, Error>

async fn query_one_as<T: DeserializeOwned>(self) -> Result<Option<T>, Error>

async fn output(self) -> Result<String, Error>

Implementors