pub async fn write_partial_result(
storage: &Arc<dyn StorageBackend>,
query_id: &str,
node_id: &NodeId,
batches: &[RecordBatch],
) -> Result<()>Expand description
Write partial result as Arrow IPC file.
pub async fn write_partial_result(
storage: &Arc<dyn StorageBackend>,
query_id: &str,
node_id: &NodeId,
batches: &[RecordBatch],
) -> Result<()>Write partial result as Arrow IPC file.