pub struct JoinStats {
pub build_records: u64,
pub build_nulls: u64,
pub duplicates: u64,
pub probe_records: u64,
pub matches: u64,
pub misses: u64,
pub project_misses: u64,
}Expand description
Running counters for a join, mirroring the faucet_join_* metrics.
Fields§
§build_records: u64Records ingested by the build side (before null-key skipping).
build_nulls: u64Build records skipped because their key resolved to null/absent.
duplicates: u64Distinct build keys that appeared more than once (duplicate keys).
probe_records: u64Records ingested by the probe side.
matches: u64Probe records that matched at least one build record.
misses: u64Probe records with no build-side match.
project_misses: u64Projections skipped because the from path was absent on the build
record.
Trait Implementations§
impl Eq for JoinStats
impl StructuralPartialEq for JoinStats
Auto Trait Implementations§
impl Freeze for JoinStats
impl RefUnwindSafe for JoinStats
impl Send for JoinStats
impl Sync for JoinStats
impl Unpin for JoinStats
impl UnsafeUnpin for JoinStats
impl UnwindSafe for JoinStats
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
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Compare self to
key and return true if they are equal.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