Skip to main content

remote_scan_client

Function remote_scan_client 

Source
pub async fn remote_scan_client(
    pool: &QueryClientPool,
    kv: &Arc<dyn ClusterKv>,
    peer: NodeId,
    table_name: &str,
    projection: Option<Vec<usize>>,
    filter_sql: Option<String>,
) -> Result<Option<RemoteBatchStream>, String>
Expand description

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.

ยงErrors

Transport/timeout while establishing; post-stream failures surface as Err items.