pub struct LiquidCachedRowGroup { /* private fields */ }Expand description
A row group in the cache.
Implementations§
Source§impl LiquidCachedRowGroup
impl LiquidCachedRowGroup
Sourcepub fn create_column(
&self,
column_id: u64,
field: Arc<Field>,
) -> Arc<LiquidCachedColumn>
pub fn create_column( &self, column_id: u64, field: Arc<Field>, ) -> Arc<LiquidCachedColumn>
Create a column in the row group.
Sourcepub fn batch_size(&self) -> usize
pub fn batch_size(&self) -> usize
Returns the batch size configured for this cached row group.
Sourcepub fn get_column(&self, column_id: u64) -> Option<Arc<LiquidCachedColumn>>
pub fn get_column(&self, column_id: u64) -> Option<Arc<LiquidCachedColumn>>
Get a column from the row group.
Sourcepub fn get_column_by_name(
&self,
column_name: &str,
) -> Option<Arc<LiquidCachedColumn>>
pub fn get_column_by_name( &self, column_name: &str, ) -> Option<Arc<LiquidCachedColumn>>
Get a column from the row group by its field name.
Sourcepub async fn evaluate_selection_with_predicate(
&self,
batch_id: BatchID,
selection: &BooleanBuffer,
predicate: &mut LiquidPredicate,
) -> Option<Result<BooleanArray, ArrowError>>
pub async fn evaluate_selection_with_predicate( &self, batch_id: BatchID, selection: &BooleanBuffer, predicate: &mut LiquidPredicate, ) -> Option<Result<BooleanArray, ArrowError>>
Evaluate a predicate on a row group.
Trait Implementations§
Auto Trait Implementations§
impl !Freeze for LiquidCachedRowGroup
impl !RefUnwindSafe for LiquidCachedRowGroup
impl Send for LiquidCachedRowGroup
impl Sync for LiquidCachedRowGroup
impl Unpin for LiquidCachedRowGroup
impl !UnwindSafe for LiquidCachedRowGroup
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> 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>
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 moreSource§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