Struct StreamingMergeBuilder 

pub struct StreamingMergeBuilder<'a> {
    streams: Vec<Pin<Box<dyn RecordBatchStream<Item = Result<RecordBatch, DataFusionError>> + Send>>>,
    sorted_spill_files: Vec<SortedSpillFile>,
    spill_manager: Option<SpillManager>,
    schema: Option<Arc<Schema>>,
    expressions: Option<&'a LexOrdering>,
    metrics: Option<BaselineMetrics>,
    batch_size: Option<usize>,
    fetch: Option<usize>,
    reservation: Option<MemoryReservation>,
    enable_round_robin_tie_breaker: bool,
}

Fields

streams: Vec<Pin<Box<dyn RecordBatchStream<Item = Result<RecordBatch, DataFusionError>> + Send>>>

sorted_spill_files: Vec<SortedSpillFile>

spill_manager: Option<SpillManager>

schema: Option<Arc<Schema>>

expressions: Option<&'a LexOrdering>

metrics: Option<BaselineMetrics>

batch_size: Option<usize>

fetch: Option<usize>

reservation: Option<MemoryReservation>

enable_round_robin_tie_breaker: bool

Implementations

impl<'a> StreamingMergeBuilder<'a>

pub fn new() -> StreamingMergeBuilder<'a>

pub fn with_streams( self, streams: Vec<Pin<Box<dyn RecordBatchStream<Item = Result<RecordBatch, DataFusionError>> + Send>>>, ) -> StreamingMergeBuilder<'a>

pub fn with_sorted_spill_files( self, sorted_spill_files: Vec<SortedSpillFile>, ) -> StreamingMergeBuilder<'a>

pub fn with_spill_manager( self, spill_manager: SpillManager, ) -> StreamingMergeBuilder<'a>

pub fn with_schema(self, schema: Arc<Schema>) -> StreamingMergeBuilder<'a>

pub fn with_expressions( self, expressions: &'a LexOrdering, ) -> StreamingMergeBuilder<'a>

pub fn with_metrics(self, metrics: BaselineMetrics) -> StreamingMergeBuilder<'a>

pub fn with_batch_size(self, batch_size: usize) -> StreamingMergeBuilder<'a>

pub fn with_fetch(self, fetch: Option<usize>) -> StreamingMergeBuilder<'a>

pub fn with_reservation( self, reservation: MemoryReservation, ) -> StreamingMergeBuilder<'a>

pub fn with_round_robin_tie_breaker( self, enable_round_robin_tie_breaker: bool, ) -> StreamingMergeBuilder<'a>

See SortPreservingMergeExec::with_round_robin_repartition for more information.

pub fn build( self, ) -> Result<Pin<Box<dyn RecordBatchStream<Item = Result<RecordBatch, DataFusionError>> + Send>>, DataFusionError>

Trait Implementations

impl<'a> Default for StreamingMergeBuilder<'a>

fn default() -> StreamingMergeBuilder<'a>

Returns the “default value” for a type.