MCPcopy Create free account
hub / github.com/apache/paimon-rust / plan_scan

Function plan_scan

crates/integrations/datafusion/src/table/mod.rs:311–323  ·  view source on GitHub ↗
(
        provider: &PaimonTableProvider,
        filters: Vec<Expr>,
        limit: Option<usize>,
    )

Source from the content-addressed store, hash-verified

309 }
310
311 async fn plan_scan(
312 provider: &PaimonTableProvider,
313 filters: Vec<Expr>,
314 limit: Option<usize>,
315 ) -> Arc<dyn ExecutionPlan> {
316 let config = SessionConfig::new().with_target_partitions(8);
317 let ctx = SessionContext::new_with_config(config);
318 let state = ctx.state();
319 provider
320 .scan(&state, None, &filters, limit)
321 .await
322 .expect("scan() should succeed")
323 }
324
325 fn extract_dt_partition_set(planned_partitions: &[Arc<[DataSplit]>]) -> BTreeSet<String> {
326 planned_partitions

Calls 1

scanMethod · 0.45