Struct mz_persist::indexed::columnar::ColumnarRecordsVecBuilder
source · pub struct ColumnarRecordsVecBuilder {
current: ColumnarRecordsBuilder,
filled: Vec<ColumnarRecords>,
key_val_data_max_len: usize,
}
Expand description
A wrapper around ColumnarRecordsBuilder that chunks as necessary to keep each ColumnarRecords within the required size bounds.
Fields§
§current: ColumnarRecordsBuilder
§filled: Vec<ColumnarRecords>
§key_val_data_max_len: usize
Implementations§
source§impl ColumnarRecordsVecBuilder
impl ColumnarRecordsVecBuilder
sourcepub fn new_with_len(key_val_data_max_len: usize) -> Self
pub fn new_with_len(key_val_data_max_len: usize) -> Self
Create a new ColumnarRecordsVecBuilder with a specified max size.
sourcepub fn len(&self) -> usize
pub fn len(&self) -> usize
The number of (potentially duplicated) ((Key, Val), Time, i64) records stored in Self.
sourcepub fn reserve(
&mut self,
additional: usize,
key_size_guess: usize,
val_size_guess: usize
)
pub fn reserve(
&mut self,
additional: usize,
key_size_guess: usize,
val_size_guess: usize
)
Reserve space for additional
more records, based on key_size_guess
and
val_size_guess
.
The guesses for key and val sizes are best effort, and if they end up being too small, the underlying buffers will be resized.
sourcepub fn finish(self) -> Vec<ColumnarRecords> ⓘ
pub fn finish(self) -> Vec<ColumnarRecords> ⓘ
Finalize constructing a Vec<ColumnarRecords>
.
sourcepub fn take_filled(&mut self) -> Vec<ColumnarRecords> ⓘ
pub fn take_filled(&mut self) -> Vec<ColumnarRecords> ⓘ
Returns the list of filled ColumnarRecords.
Trait Implementations§
source§impl Debug for ColumnarRecordsVecBuilder
impl Debug for ColumnarRecordsVecBuilder
Auto Trait Implementations§
impl RefUnwindSafe for ColumnarRecordsVecBuilder
impl Send for ColumnarRecordsVecBuilder
impl Sync for ColumnarRecordsVecBuilder
impl Unpin for ColumnarRecordsVecBuilder
impl UnwindSafe for ColumnarRecordsVecBuilder
Blanket Implementations§
source§impl<T> FutureExt for T
impl<T> FutureExt for T
source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
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> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T
in a tonic::Request
source§impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
source§fn into_rust(self) -> Result<R, TryFromProtoError>
fn into_rust(self) -> Result<R, TryFromProtoError>
See
RustType::from_proto
.source§fn from_rust(rust: &R) -> P
fn from_rust(rust: &R) -> P
See
RustType::into_proto
.