Skip to main content

FragmentTableSource

mongreldb_query::distributed

Trait FragmentTableSource 

Source 
pub trait FragmentTableSource: Send + Sync {
    // Required methods
    fn scan(
        &self,
        table: &str,
        tablet: TabletId,
        include_row_id: bool,
        control: Option<&FragmentControl>,
    ) -> DistributedResult<Vec<RecordBatch>>;
    fn schema(
        &self,
        table: &str,
        tablet: TabletId,
    ) -> DistributedResult<Option<SchemaRef>>;
}
Expand description

Batch source consumed by the reference fragment operator engine.

Implementations validate control.authorization_context before reading.

Required Methods§

Source

fn scan( &self, table: &str, tablet: TabletId, include_row_id: bool, control: Option<&FragmentControl>, ) -> DistributedResult<Vec<RecordBatch>>

Reads one table slice from a hosted tablet.

Source

fn schema( &self, table: &str, tablet: TabletId, ) -> DistributedResult<Option<SchemaRef>>

Returns the empty-result schema for one table, when known.

Dyn Compatibility§

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§