pub struct RepartitionStrategy { /* private fields */ }Expand description
Repartition a stream of arrays into blocks.
Each emitted block (except the last) is at least block_size_minimum bytes and contains a
multiple of block_len_multiple rows.
Implementations§
Source§impl RepartitionStrategy
impl RepartitionStrategy
pub fn new( child: ArcRef<dyn LayoutStrategy>, options: RepartitionWriterOptions, ) -> Self
Trait Implementations§
Source§impl LayoutStrategy for RepartitionStrategy
impl LayoutStrategy for RepartitionStrategy
fn write_stream( &self, ctx: &ArrayContext, sequence_writer: SequenceWriter, stream: SendableSequentialStream, ) -> SendableLayoutFuture
Auto Trait Implementations§
impl Freeze for RepartitionStrategy
impl !RefUnwindSafe for RepartitionStrategy
impl Send for RepartitionStrategy
impl Sync for RepartitionStrategy
impl Unpin for RepartitionStrategy
impl !UnwindSafe for RepartitionStrategy
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