Enum QueryMessage 

pub enum QueryMessage {
    ExecuteFragment {
        execution_id: String,
        stage_id: usize,
        plans_bytes: Vec<Vec<u8>>,
        coordinator_addr: String,
    },
    FragmentCompleted {
        execution_id: String,
        stage_id: usize,
    },
    ExchangeData {
        execution_id: String,
        exchange_id: usize,
        node_id: u32,
        is_eof: bool,
        batch_data: Vec<u8>,
    },
}

분산 쿼리 코디네이팅 전용 프로토콜

Variants

ExecuteFragment

하위 노드에 쿼리 파편(Fragment) 실행 요청

Fields

execution_id: String

stage_id: usize

plans_bytes: Vec<Vec<u8>>

bincode 직렬화된 여러 개의 PhysicalPlan 바이너리

coordinator_addr: String

코디네이터 주소 — 워커가 결과를 역전송할 목적지

FragmentCompleted

코디네이터에게 특정 워커가 스테이지의 모든 플랜 실행을 완료했음을 보고

Fields

execution_id: String

stage_id: usize

ExchangeData

코디네이터로 RecordBatch 배압(Backpressure) 전송 스트림. (Arrow IPC 포맷 - FlatBuffer 내장)

Fields

execution_id: String

exchange_id: usize

(신규) 다중 Exchange 스트림을 식별하기 위한 고유 ID

node_id: u32

송신 워커 노드 식별자 (멀티 워커 집계 시 출처 추적용)

is_eof: bool

batch_data: Vec<u8>

Trait Implementations

impl Clone for QueryMessage

fn clone(&self) -> QueryMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for QueryMessage

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for QueryMessage

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for QueryMessage

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

Tests for self and other values to be equal, and is used by ==.

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

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

impl Serialize for QueryMessage

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for QueryMessage