pub async fn local_execute(
session: Arc<SessionImpl>,
query: Query,
can_timeout_cancel: bool,
read_storage_tables: &HashSet<TableId>,
) -> Result<ReceiverStream<Result<DataChunk, BoxedError>>, RwError>
pub async fn local_execute(
session: Arc<SessionImpl>,
query: Query,
can_timeout_cancel: bool,
read_storage_tables: &HashSet<TableId>,
) -> Result<ReceiverStream<Result<DataChunk, BoxedError>>, RwError>