Trait TableJoinExt 

pub trait TableJoinExt<P>
where
    P: Pager<Blob = EntryHandle> + Send + Sync,
{
    // Required method
    fn join_stream<F>(
        &self,
        right: &Table<P>,
        keys: &[JoinKey],
        options: &JoinOptions,
        on_batch: F,
    ) -> LlkvResult<()>
       where F: FnMut(RecordBatch);
}

Extension trait adding join operations to Table.

Required Methods

fn join_stream<F>( &self, right: &Table<P>, keys: &[JoinKey], options: &JoinOptions, on_batch: F, ) -> LlkvResult<()>

where F: FnMut(RecordBatch),

Join this table with another table based on equality predicates.

Dyn Compatibility

This trait is not dyn compatible.

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

Implementations on Foreign Types

impl<P> TableJoinExt<P> for Table<P>

where P: Pager<Blob = EntryHandle> + Send + Sync,

fn join_stream<F>( &self, right: &Table<P>, keys: &[JoinKey], options: &JoinOptions, on_batch: F, ) -> LlkvResult<()>

where F: FnMut(RecordBatch),

Implementors