Struct StreamingMergeBuilder 

pub struct StreamingMergeBuilder<'a> {
    streams: Vec<SendableRecordBatchStream>,
    sorted_spill_files: Vec<SortedSpillFile>,
    spill_manager: Option<SpillManager>,
    schema: Option<SchemaRef>,
    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<SendableRecordBatchStream>

sorted_spill_files: Vec<SortedSpillFile>

spill_manager: Option<SpillManager>

schema: Option<SchemaRef>

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() -> Self

pub fn with_streams(self, streams: Vec<SendableRecordBatchStream>) -> Self

pub fn with_sorted_spill_files( self, sorted_spill_files: Vec<SortedSpillFile>, ) -> Self

pub fn with_spill_manager(self, spill_manager: SpillManager) -> Self

pub fn with_schema(self, schema: SchemaRef) -> Self

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

pub fn with_metrics(self, metrics: BaselineMetrics) -> Self

pub fn with_batch_size(self, batch_size: usize) -> Self

pub fn with_fetch(self, fetch: Option<usize>) -> Self

pub fn with_reservation(self, reservation: MemoryReservation) -> Self

pub fn with_round_robin_tie_breaker( self, enable_round_robin_tie_breaker: bool, ) -> Self

See SortPreservingMergeExec::with_round_robin_repartition for more information.

pub(super) fn with_bypass_mempool(self) -> Self

Bypass the mempool and avoid using the memory reservation.

This is not marked as pub because it is not recommended to use this method

pub fn build(self) -> Result<SendableRecordBatchStream>

Trait Implementations

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

fn default() -> StreamingMergeBuilder<'a>

Returns the “default value” for a type.