pub struct SqlExecutionMetrics { /* private fields */ }Expand description
Per-query counters populated by SQL lowering and native Datum stages.
Implementations§
Source§impl SqlExecutionMetrics
impl SqlExecutionMetrics
Sourcepub fn late_dropped_rows(&self) -> u64
pub fn late_dropped_rows(&self) -> u64
Rows dropped after the active watermark in windowed or joined streams.
Sourcepub fn streaming_join_metrics(&self) -> StreamingJoinMetrics
pub fn streaming_join_metrics(&self) -> StreamingJoinMetrics
Returns a snapshot handle for streaming join counters.
Sourcepub fn join_state_rows(&self) -> u64
pub fn join_state_rows(&self) -> u64
Rows currently retained by streaming join state.
Sourcepub fn join_evicted_rows(&self) -> u64
pub fn join_evicted_rows(&self) -> u64
Rows evicted from streaming join state by watermark progress.
Trait Implementations§
Source§impl Clone for SqlExecutionMetrics
impl Clone for SqlExecutionMetrics
Source§fn clone(&self) -> SqlExecutionMetrics
fn clone(&self) -> SqlExecutionMetrics
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for SqlExecutionMetrics
impl Debug for SqlExecutionMetrics
Source§impl Default for SqlExecutionMetrics
impl Default for SqlExecutionMetrics
Source§fn default() -> SqlExecutionMetrics
fn default() -> SqlExecutionMetrics
Returns the “default value” for a type. Read more
Auto Trait Implementations§
impl Freeze for SqlExecutionMetrics
impl RefUnwindSafe for SqlExecutionMetrics
impl Send for SqlExecutionMetrics
impl Sync for SqlExecutionMetrics
impl Unpin for SqlExecutionMetrics
impl UnsafeUnpin for SqlExecutionMetrics
impl UnwindSafe for SqlExecutionMetrics
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
Mutably borrows from an owned value. Read more
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
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> Message for T
impl<T> Message for T
Source§fn from_boxed(m: BoxedMessage) -> Result<Self, BoxedDowncastErr>
fn from_boxed(m: BoxedMessage) -> Result<Self, BoxedDowncastErr>
Convert a BoxedMessage to this concrete type
Source§fn box_message(self, pid: &ActorId) -> Result<BoxedMessage, BoxedDowncastErr>
fn box_message(self, pid: &ActorId) -> Result<BoxedMessage, BoxedDowncastErr>
Convert this message to a BoxedMessage