BatchTransformer

datafusion_physical_plan::joins::utils

Trait BatchTransformer 

Source 
pub(crate) trait BatchTransformer: Debug + Clone {
    // Required methods
    fn set_batch(&mut self, batch: RecordBatch);
    fn next(&mut self) -> Option<(RecordBatch, bool)>;
}
Expand description

Trait for incrementally generating Join output.

This trait is used to limit some join outputs so it does not produce single large batches

Required Methods§

Source

fn set_batch(&mut self, batch: RecordBatch)

Sets the next RecordBatch to be processed.

Source

fn next(&mut self) -> Option<(RecordBatch, bool)>

Retrieves the next RecordBatch from the transformer. Returns None if all batches have been produced. The boolean flag indicates whether the batch is the last one.

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors§