Struct SharedDataFusionEngine 

pub struct SharedDataFusionEngine(pub Arc<DataFusionEngine>);

A cheaply-cloneable, Arc-wrapped DataFusionEngine that implements rhei_core::OlapEngine.

All method calls delegate to the inner engine. Cloning a SharedDataFusionEngine only increments the reference count — the underlying engine (and its table store) is shared.

Use SharedDataFusionEngine::new to construct from a DataFusionEngine, or access the inner engine through the public Deref impl or the 0 field.

Tuple Fields

0: Arc<DataFusionEngine>

Implementations

impl SharedDataFusionEngine

pub fn new(engine: DataFusionEngine) -> Self

Wrap a DataFusionEngine in an Arc so it can be shared across tasks.

Methods from Deref<Target = DataFusionEngine>

pub fn storage_mode(&self) -> &StorageMode

Returns the storage mode of this engine.

Trait Implementations

impl Clone for SharedDataFusionEngine

fn clone(&self) -> SharedDataFusionEngine

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Deref for SharedDataFusionEngine

type Target = DataFusionEngine

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl OlapEngine for SharedDataFusionEngine

type Error = DfOlapError

Engine-specific error type returned by all fallible methods.

async fn query(&self, sql: &str) -> Result<Vec<RecordBatch>, Self::Error>

Execute an analytical SQL query and return results as Arrow RecordBatches buffered in memory.

async fn query_stream( &self, sql: &str, ) -> Result<RecordBatchBoxStream, Self::Error>

Execute a SQL query and return a lazy RecordBatchBoxStream.

async fn execute(&self, sql: &str) -> Result<u64, Self::Error>

Execute a DDL or DML statement without returning rows.

async fn load_arrow( &self, table: &str, batches: &[RecordBatch], ) -> Result<u64, Self::Error>

Bulk-load Arrow RecordBatches into table.

async fn create_table( &self, table_name: &str, schema: &SchemaRef, primary_key: &[String], ) -> Result<(), Self::Error>

Create a table from an Arrow schema with an optional primary key.

async fn table_exists(&self, table_name: &str) -> Result<bool, Self::Error>

Return true if table_name exists in the OLAP catalog.

async fn add_column( &self, table_name: &str, column_name: &str, data_type: &DataType, ) -> Result<(), Self::Error>

Add a nullable column to an existing table.

async fn drop_column( &self, table_name: &str, column_name: &str, ) -> Result<(), Self::Error>

Remove a column from an existing table.

fn supports_transactions(&self) -> bool

Returns true if this backend supports ACID transactions via BEGIN / COMMIT / ROLLBACK.