Skip to main content

DatabaseSql

dbx_core::traits

Trait DatabaseSql 

Source 
pub trait DatabaseSql {
    // Required methods
    fn execute_sql(&self, sql: &str) -> DbxResult<Vec<RecordBatch>>;
    fn register_table(&self, name: &str, batches: Vec<RecordBatch>);
    fn append_batch(&self, table: &str, batch: RecordBatch) -> DbxResult<()>;
}
Expand description

SQL 실행 기능을 제공하는 Trait

Required Methods§

Source

fn execute_sql(&self, sql: &str) -> DbxResult<Vec<RecordBatch>>

SQL 문 실행 (RecordBatch는 engine에서 정의)

Source

fn register_table(&self, name: &str, batches: Vec<RecordBatch>)

테이블 등록 (Arrow RecordBatch)

Source

fn append_batch(&self, table: &str, batch: RecordBatch) -> DbxResult<()>

배치 추가

Implementors§