pub struct StreamingMergeBuilder<'a> { /* private fields */ }Implementations§
Source§impl<'a> StreamingMergeBuilder<'a>
impl<'a> StreamingMergeBuilder<'a>
pub fn new() -> Self
pub fn with_streams(self, streams: Vec<SendableRecordBatchStream>) -> Self
pub fn with_schema(self, schema: SchemaRef) -> Self
pub fn with_expressions(self, expressions: LexOrderingRef<'a>) -> 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
pub fn build(self) -> Result<SendableRecordBatchStream>
Trait Implementations§
Source§impl<'a> Default for StreamingMergeBuilder<'a>
impl<'a> Default for StreamingMergeBuilder<'a>
Source§fn default() -> StreamingMergeBuilder<'a>
fn default() -> StreamingMergeBuilder<'a>
Returns the “default value” for a type. Read more
Auto Trait Implementations§
impl<'a> Freeze for StreamingMergeBuilder<'a>
impl<'a> !RefUnwindSafe for StreamingMergeBuilder<'a>
impl<'a> Send for StreamingMergeBuilder<'a>
impl<'a> !Sync for StreamingMergeBuilder<'a>
impl<'a> Unpin for StreamingMergeBuilder<'a>
impl<'a> !UnwindSafe for StreamingMergeBuilder<'a>
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more