Module query 

In-engine distributed query (pull path): a coordinator fans RemoteScan out to peers owning part of a table/MV and unions their Arrow batches.

Traits

RemoteQueryHandler

Node-local provider of table / materialized-view snapshots for remote scans.

Functions

remote_scan_client

Scan table_name on peer as a lazy Arrow-IPC stream. Ok(None) means the peer is unreachable (no published address) and should be skipped, not failed.

Type Aliases

QueryClientPool

Pooled per-peer channels for RemoteScan, reused across queries and evicted on RPC failure so a restarted peer is re-resolved.

QueryHandlerSlot

Handler slot read per request, so registration and server start are order-independent.

RemoteBatchStream

Lazily-streamed Arrow [RecordBatch] chunks from a peer’s RemoteScan; a decode or mid-stream transport error surfaces as an Err item.