Struct ExplainQueryStage

pub struct ExplainQueryStage {

    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>,
}

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

impl Clone for ExplainQueryStage

fn clone(&self) -> ExplainQueryStage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ExplainQueryStage

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

Formats the value using the given formatter.

impl Default for ExplainQueryStage

fn default() -> ExplainQueryStage

Returns the “default value” for a type.

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

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ExplainQueryStage

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Part for ExplainQueryStage