Skip to main content

EpistemicGpuRuntimeWcojCertification

Enum EpistemicGpuRuntimeWcojCertification 

Source
pub enum EpistemicGpuRuntimeWcojCertification {
    NotRequired {
        observed_wcoj_dispatches: u64,
        planned_hash_routes: usize,
        planned_hash_planner_wins: usize,
        planned_hash_incomplete_stats: usize,
        planned_hash_cost_evidence: usize,
    },
    Certified {
Show 16 fields observed_wcoj_dispatches: u64, certified_multiway_reductions: usize, observed_kclique_dispatches: u64, certified_edge_permutation_slots: usize, certified_stream_groups: usize, certified_skew_scheduled_plans: usize, certified_sorted_layout_requirements: usize, certified_helper_split_specs: usize, certified_helper_relation_rules: usize, certified_helper_relation_scans: usize, observed_layout_sorts: u64, observed_layout_fast_path_hits: u64, observed_metadata_builds: u64, observed_metadata_build_nanos: u64, observed_histogram_refreshes: u64, observed_histogram_refresh_nanos: u128,
}, MissingRequiredWcojLayout { required_sorted_layouts: usize, observed_layout_events: u64, }, MissingRequiredKcliqueMetadata { required_kclique_plans: usize, observed_metadata_builds: u64, observed_metadata_build_nanos: u64, }, MissingRequiredWcojDispatch { required_multiway_reductions: usize, required_kclique_plans: usize, observed_wcoj_dispatches: u64, observed_kclique_dispatches: u64, }, }
Expand description

WCOJ certification status for an epistemic runtime dispatch attempt.

Variants§

§

NotRequired

The preflight did not require a WCOJ dispatch.

Fields

§observed_wcoj_dispatches: u64

Observed executor-installed WCOJ dispatches.

§planned_hash_routes: usize

Structured planned-hash routes that replaced WCOJ dispatch obligations.

§planned_hash_planner_wins: usize

Planned-hash routes where complete planner costs predicted hash wins.

§planned_hash_incomplete_stats: usize

Planned-hash routes selected because complete WCOJ stats were unavailable.

§planned_hash_cost_evidence: usize

Planned-hash routes carrying finite hash-vs-WCOJ cost evidence.

§

Certified

Runtime counters prove the required WCOJ dispatch happened.

Fields

§observed_wcoj_dispatches: u64

Observed executor-installed WCOJ dispatches.

§certified_multiway_reductions: usize

MultiWayJoin reductions certified by the observed WCOJ dispatches.

§observed_kclique_dispatches: u64

Observed executor-installed K-clique dispatches.

§certified_edge_permutation_slots: usize

Edge-permutation slots certified by the dispatched K-clique plans.

§certified_stream_groups: usize

Distinct stream groups certified by the dispatched K-clique plans.

§certified_skew_scheduled_plans: usize

Helper-split skew-scheduled K-clique plans certified by dispatch.

§certified_sorted_layout_requirements: usize

Sorted-layout requirements certified by the dispatched K-clique plans.

§certified_helper_split_specs: usize

Helper-split specs certified by the dispatched K-clique plans.

§certified_helper_relation_rules: usize

Helper relation rules proving production helper-split rewrite happened.

§certified_helper_relation_scans: usize

Helper relation scans proving WCOJ consumed production helper output.

§observed_layout_sorts: u64

Observed provider WCOJ layout-sort invocations.

§observed_layout_fast_path_hits: u64

Observed provider WCOJ layout fast-path hits.

§observed_metadata_builds: u64

Observed provider K-clique metadata builds.

§observed_metadata_build_nanos: u64

Observed provider time spent building K-clique metadata.

§observed_histogram_refreshes: u64

Observed recursive K-clique histogram refresh boundaries.

§observed_histogram_refresh_nanos: u128

Observed recursive K-clique histogram refresh accounting time.

§

MissingRequiredWcojLayout

The plan required sorted layouts, but no layout path executed.

Fields

§required_sorted_layouts: usize

Sorted-layout requirements found during preflight.

§observed_layout_events: u64

Observed layout sort or fast-path events.

§

MissingRequiredKcliqueMetadata

The plan dispatched a K-clique WCOJ route, but metadata-build counters did not advance.

Fields

§required_kclique_plans: usize

K-clique WCOJ plans found during preflight.

§observed_metadata_builds: u64

Observed provider K-clique metadata builds.

§observed_metadata_build_nanos: u64

Observed provider time spent building K-clique metadata.

§

MissingRequiredWcojDispatch

The plan had WCOJ obligations, but counters did not advance.

Fields

§required_multiway_reductions: usize

MultiWayJoin reductions found during preflight after excluding planned hash routes.

§required_kclique_plans: usize

K-clique WCOJ plans found during preflight.

§observed_wcoj_dispatches: u64

Observed executor-installed WCOJ dispatches.

§observed_kclique_dispatches: u64

Observed executor-installed K-clique dispatches.

Implementations§

Source§

impl EpistemicGpuRuntimeWcojCertification

Source

pub fn for_preflight_and_delta( preflight: &EpistemicGpuRuntimePreflight, delta: &EpistemicGpuRuntimeCounters, ) -> Self

Compare static preflight obligations with runtime counter deltas.

Source

pub fn try_for_preflight_and_delta( preflight: &EpistemicGpuRuntimePreflight, delta: &EpistemicGpuRuntimeCounters, ) -> Result<Self>

Compare static preflight obligations with runtime counter deltas, failing closed if certification counters overflow while being summarized.

Trait Implementations§

Source§

impl Clone for EpistemicGpuRuntimeWcojCertification

Source§

fn clone(&self) -> EpistemicGpuRuntimeWcojCertification

Returns a duplicate of the value. Read more
1.0.0 · Source§

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source. Read more
Source§

impl Debug for EpistemicGpuRuntimeWcojCertification

Source§

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more
Source§

impl PartialEq for EpistemicGpuRuntimeWcojCertification

Source§

fn eq(&self, other: &EpistemicGpuRuntimeWcojCertification) -> bool

Tests for self and other values to be equal, and is used by ==.
1.0.0 · Source§

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.
Source§

impl Copy for EpistemicGpuRuntimeWcojCertification

Source§

impl Eq for EpistemicGpuRuntimeWcojCertification

Source§

impl StructuralPartialEq for EpistemicGpuRuntimeWcojCertification

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
§

impl<Q, K> Equivalent<K> for Q
where Q: Eq + ?Sized, K: Borrow<Q> + ?Sized,

§

fn equivalent(&self, key: &K) -> bool

Checks if this value is equivalent to the given key. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
§

impl<T> Allocation for T
where T: RefUnwindSafe + Send + Sync,