pub struct AppendRequest<S> { /* private fields */ }Expand description
One Arrow source plus physical settings for a single append.
Pass the source directly to TimeSeriesTable::append to use the current
Parquet writer defaults. Wrap it in AppendRequest only when one append
needs an explicit output row-group limit. A nested request inherits its
source’s limit unless the outer request replaces it.
Implementations§
Source§impl<S> AppendRequest<S>
impl<S> AppendRequest<S>
Sourcepub fn new(source: S) -> Self
pub fn new(source: S) -> Self
Create a request without adding a row-group override.
Ordinary Arrow sources therefore use the current Parquet writer
defaults. If source already carries a limit, this request inherits it
until max_rows_per_row_group replaces
it.
Sourcepub fn max_rows_per_row_group(self, max_rows_per_row_group: usize) -> Self
pub fn max_rows_per_row_group(self, max_rows_per_row_group: usize) -> Self
Limit output Parquet row groups to this many rows for this append.
This controls rows, not bytes, input batches, or source-file row-group
boundaries, and replaces any limit already carried by the source. Zero
is rejected by TimeSeriesTable::append before the source is inspected
or consumed.
Trait Implementations§
Auto Trait Implementations§
impl<S> Freeze for AppendRequest<S>where
S: Freeze,
impl<S> RefUnwindSafe for AppendRequest<S>where
S: RefUnwindSafe,
impl<S> Send for AppendRequest<S>where
S: Send,
impl<S> Sync for AppendRequest<S>where
S: Sync,
impl<S> Unpin for AppendRequest<S>where
S: Unpin,
impl<S> UnsafeUnpin for AppendRequest<S>where
S: UnsafeUnpin,
impl<S> UnwindSafe for AppendRequest<S>where
S: UnwindSafe,
Blanket Implementations§
impl<T> Allocation for T
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
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
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> ⓘ
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> ⓘ
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