Skip to main content

candidate_primary_key_stream

Function candidate_primary_key_stream 

Source
fn candidate_primary_key_stream(
    input: BoxedRecordBatchStream,
    filter: Option<CachedPrimaryKeyFilter>,
) -> BoxedRecordBatchStream
Expand description

Filters a source by encoded-primary-key predicates and emits one binary row per local key.