Struct QueryStage

pub struct QueryStage {

    pub query_id: QueryId,
    pub id: u32,
    pub root: Arc<ExecutionPlanNode>,
    pub exchange_info: Option<ExchangeInfo>,
    pub parallelism: Option<u32>,
    pub table_scan_info: Option<TableScanInfo>,
    pub source_info: Option<SourceScanInfo>,
    pub file_scan_info: Option<FileScanInfo>,
    pub has_lookup_join: bool,
    pub dml_table_id: Option<TableId>,
    pub session_id: SessionId,
    pub batch_enable_distributed_dml: bool,
    children_exchange_distribution: Option<HashMap<u32, Distribution>>,
}

Fragment part of Query.

Fields

query_id: QueryId

id: u32

root: Arc<ExecutionPlanNode>

exchange_info: Option<ExchangeInfo>

parallelism: Option<u32>

table_scan_info: Option<TableScanInfo>

Indicates whether this stage contains a table scan node and the table’s information if so.

source_info: Option<SourceScanInfo>

file_scan_info: Option<FileScanInfo>

has_lookup_join: bool

dml_table_id: Option<TableId>

session_id: SessionId

batch_enable_distributed_dml: bool

children_exchange_distribution: Option<HashMap<u32, Distribution>>

Used to generate exchange information when complete source scan information.

Implementations

impl QueryStage

pub fn has_table_scan(&self) -> bool

If true, this stage contains table scan executor that creates Hummock iterators to read data from table. The iterator is initialized during the executor building process on the batch execution engine.

pub fn has_lookup_join(&self) -> bool

If true, this stage contains lookup join executor. We need to delay epoch unpin util the end of the query.

pub fn clone_with_exchange_info( &self, exchange_info: Option<ExchangeInfo>, parallelism: Option<u32>, ) -> Self

pub fn clone_with_exchange_info_and_complete_source_info( &self, exchange_info: Option<ExchangeInfo>, source_info: SourceScanInfo, task_parallelism: u32, ) -> Self

Trait Implementations

impl Clone for QueryStage

fn clone(&self) -> QueryStage

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for QueryStage

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

Formats the value using the given formatter.

impl Serialize for QueryStage

fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>

where S: Serializer,

Serialize this value into the given Serde serializer.