pub struct StreamChunkMut {
columns: Arc<[ArrayRef]>,
ops: OpsMut,
vis: BitmapBuilder,
}
Expand description
A mutable wrapper for StreamChunk
. can only set the visibilities and ops in place, can not
change the length.
Fields§
§columns: Arc<[ArrayRef]>
§ops: OpsMut
§vis: BitmapBuilder
Implementations§
source§impl StreamChunkMut
impl StreamChunkMut
pub fn capacity(&self) -> usize
pub fn vis(&self, i: usize) -> bool
pub fn op(&self, i: usize) -> Op
pub fn row_ref(&self, i: usize) -> RowRef<'_>
pub fn set_vis(&mut self, n: usize, val: bool)
pub fn set_op(&mut self, n: usize, val: Op)
pub fn columns(&self) -> &[ArrayRef]
sourcepub fn to_rows_mut(
&mut self,
) -> impl Iterator<Item = (RowRef<'_>, OpRowMutRef<'_>)>
pub fn to_rows_mut( &mut self, ) -> impl Iterator<Item = (RowRef<'_>, OpRowMutRef<'_>)>
get the mut reference of the stream chunk.
Trait Implementations§
source§impl From<StreamChunk> for StreamChunkMut
impl From<StreamChunk> for StreamChunkMut
source§fn from(c: StreamChunk) -> Self
fn from(c: StreamChunk) -> Self
Converts to this type from the input type.
source§impl From<StreamChunkMut> for StreamChunk
impl From<StreamChunkMut> for StreamChunk
source§fn from(c: StreamChunkMut) -> Self
fn from(c: StreamChunkMut) -> Self
Converts to this type from the input type.
Auto Trait Implementations§
impl Freeze for StreamChunkMut
impl RefUnwindSafe for StreamChunkMut
impl Send for StreamChunkMut
impl Sync for StreamChunkMut
impl Unpin for StreamChunkMut
impl UnwindSafe for StreamChunkMut
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
§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<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> 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
§impl<T> IntoResult<T> for T
impl<T> IntoResult<T> for T
type Err = Infallible
fn into_result(self) -> Result<T, <T as IntoResult<T>>::Err>
source§impl<M> MetricVecRelabelExt for M
impl<M> MetricVecRelabelExt for M
source§fn relabel(
self,
metric_level: MetricLevel,
relabel_threshold: MetricLevel,
) -> RelabeledMetricVec<M>
fn relabel( self, metric_level: MetricLevel, relabel_threshold: MetricLevel, ) -> RelabeledMetricVec<M>
Equivalent to
RelabeledMetricVec::with_metric_level
.source§fn relabel_n(
self,
metric_level: MetricLevel,
relabel_threshold: MetricLevel,
relabel_num: usize,
) -> RelabeledMetricVec<M>
fn relabel_n( self, metric_level: MetricLevel, relabel_threshold: MetricLevel, relabel_num: usize, ) -> RelabeledMetricVec<M>
Equivalent to
RelabeledMetricVec::with_metric_level_relabel_n
.source§fn relabel_debug_1(
self,
relabel_threshold: MetricLevel,
) -> RelabeledMetricVec<M>
fn relabel_debug_1( self, relabel_threshold: MetricLevel, ) -> RelabeledMetricVec<M>
Equivalent to
RelabeledMetricVec::with_metric_level_relabel_n
with metric_level
set to
MetricLevel::Debug
and relabel_num
set to 1.