hash_join_stream

Function hash_join_stream 

Source
pub fn hash_join_stream<P, F>(
    left: &Table<P>,
    right: &Table<P>,
    keys: &[JoinKey],
    options: &JoinOptions,
    on_batch: F,
) -> Result<()>
where P: Pager<Blob = EntryHandle> + Send + Sync, F: FnMut(RecordBatch),
Expand description

Execute a hash join between two tables and stream joined batches to on_batch.

Supports Inner, Left, Semi, and Anti joins today. Right and Full outer joins return an llkv_result::Error::Internal since their probe phases are not wired up yet.