MCPcopy Create free account
hub / github.com/apache/datafusion / new

Method new

datafusion/datasource/src/file_stream/mod.rs:65–76  ·  view source on GitHub ↗
(
        config: &FileScanConfig,
        partition: usize,
        file_opener: Arc<dyn FileOpener>,
        metrics: &ExecutionPlanMetricsSet,
    )

Source from the content-addressed store, hash-verified

63 /// Create a new `FileStream` using the give `FileOpener` to scan underlying files
64 #[deprecated(since = "54.0.0", note = "Use FileStreamBuilder instead")]
65 pub fn new(
66 config: &FileScanConfig,
67 partition: usize,
68 file_opener: Arc<dyn FileOpener>,
69 metrics: &ExecutionPlanMetricsSet,
70 ) -> Result<Self> {
71 FileStreamBuilder::new(config)
72 .with_partition(partition)
73 .with_file_opener(file_opener)
74 .with_metrics(metrics)
75 .build()
76 }
77
78 /// Specify the behavior when an error occurs opening or scanning a file
79 ///

Callers

nothing calls this directly

Calls 5

newFunction · 0.85
buildMethod · 0.45
with_metricsMethod · 0.45
with_file_openerMethod · 0.45
with_partitionMethod · 0.45

Tested by

no test coverage detected