pub struct ExplainQueryStage {
Show 30 fields pub completed_parallel_inputs: Option<i64>, pub compute_ms_avg: Option<i64>, pub compute_ms_max: Option<i64>, pub compute_ratio_avg: Option<f64>, pub compute_ratio_max: Option<f64>, pub end_ms: Option<i64>, pub id: Option<i64>, pub input_stages: Option<Vec<i64>>, pub name: Option<String>, pub parallel_inputs: Option<i64>, pub read_ms_avg: Option<i64>, pub read_ms_max: Option<i64>, pub read_ratio_avg: Option<f64>, pub read_ratio_max: Option<f64>, pub records_read: Option<i64>, pub records_written: Option<i64>, pub shuffle_output_bytes: Option<i64>, pub shuffle_output_bytes_spilled: Option<i64>, pub slot_ms: Option<i64>, pub start_ms: Option<i64>, pub status: Option<String>, pub steps: Option<Vec<ExplainQueryStep>>, pub wait_ms_avg: Option<i64>, pub wait_ms_max: Option<i64>, pub wait_ratio_avg: Option<f64>, pub wait_ratio_max: Option<f64>, pub write_ms_avg: Option<i64>, pub write_ms_max: Option<i64>, pub write_ratio_avg: Option<f64>, pub write_ratio_max: Option<f64>,
}
Expand description

There is no detailed description.

This type is not used in any activity, and only used as part of another schema.

Fields§

§completed_parallel_inputs: Option<i64>

Number of parallel input segments completed.

§compute_ms_avg: Option<i64>

Milliseconds the average shard spent on CPU-bound tasks.

§compute_ms_max: Option<i64>

Milliseconds the slowest shard spent on CPU-bound tasks.

§compute_ratio_avg: Option<f64>

Relative amount of time the average shard spent on CPU-bound tasks.

§compute_ratio_max: Option<f64>

Relative amount of time the slowest shard spent on CPU-bound tasks.

§end_ms: Option<i64>

Stage end time represented as milliseconds since epoch.

§id: Option<i64>

Unique ID for stage within plan.

§input_stages: Option<Vec<i64>>

IDs for stages that are inputs to this stage.

§name: Option<String>

Human-readable name for stage.

§parallel_inputs: Option<i64>

Number of parallel input segments to be processed.

§read_ms_avg: Option<i64>

Milliseconds the average shard spent reading input.

§read_ms_max: Option<i64>

Milliseconds the slowest shard spent reading input.

§read_ratio_avg: Option<f64>

Relative amount of time the average shard spent reading input.

§read_ratio_max: Option<f64>

Relative amount of time the slowest shard spent reading input.

§records_read: Option<i64>

Number of records read into the stage.

§records_written: Option<i64>

Number of records written by the stage.

§shuffle_output_bytes: Option<i64>

Total number of bytes written to shuffle.

§shuffle_output_bytes_spilled: Option<i64>

Total number of bytes written to shuffle and spilled to disk.

§slot_ms: Option<i64>

Slot-milliseconds used by the stage.

§start_ms: Option<i64>

Stage start time represented as milliseconds since epoch.

§status: Option<String>

Current status for the stage.

§steps: Option<Vec<ExplainQueryStep>>

List of operations within the stage in dependency order (approximately chronological).

§wait_ms_avg: Option<i64>

Milliseconds the average shard spent waiting to be scheduled.

§wait_ms_max: Option<i64>

Milliseconds the slowest shard spent waiting to be scheduled.

§wait_ratio_avg: Option<f64>

Relative amount of time the average shard spent waiting to be scheduled.

§wait_ratio_max: Option<f64>

Relative amount of time the slowest shard spent waiting to be scheduled.

§write_ms_avg: Option<i64>

Milliseconds the average shard spent on writing output.

§write_ms_max: Option<i64>

Milliseconds the slowest shard spent on writing output.

§write_ratio_avg: Option<f64>

Relative amount of time the average shard spent on writing output.

§write_ratio_max: Option<f64>

Relative amount of time the slowest shard spent on writing output.

Trait Implementations§

source§

impl Clone for ExplainQueryStage

source§

fn clone(&self) -> ExplainQueryStage

Returns a copy 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 ExplainQueryStage

source§

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

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

impl Default for ExplainQueryStage

source§

fn default() -> ExplainQueryStage

Returns the “default value” for a type. Read more
source§

impl<'de> Deserialize<'de> for ExplainQueryStage

source§

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer. Read more
source§

impl Serialize for ExplainQueryStage

source§

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>where __S: Serializer,

Serialize this value into the given Serde serializer. Read more
source§

impl Part for ExplainQueryStage

Auto Trait Implementations§

Blanket Implementations§

source§

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

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

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

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

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

source§

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

Mutably borrows from an owned value. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T> Instrument for T

source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
source§

impl<T, U> Into<U> for Twhere 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 Twhere T: Clone,

§

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 Twhere U: Into<T>,

§

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 Twhere U: TryFrom<T>,

§

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.
source§

impl<T> WithSubscriber for T

source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more
source§

impl<T> DeserializeOwned for Twhere T: for<'de> Deserialize<'de>,