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

Method finish

datafusion/catalog/src/async.rs:93–103  ·  view source on GitHub ↗
(self)

Source from the content-addressed store, hash-verified

91 }
92
93 fn finish(self) -> Arc<dyn SchemaProvider> {
94 let cached_tables = self
95 .cached_tables
96 .into_iter()
97 .filter_map(|(key, maybe_value)| maybe_value.map(|value| (key, value)))
98 .collect();
99 Arc::new(ResolvedSchemaProvider {
100 owner_name: Some(self.owner_name),
101 cached_tables,
102 })
103 }
104}
105
106/// A catalog provider that looks up schemas in a cache

Callers 3

try_newMethod · 0.45
resolveMethod · 0.45
resolveMethod · 0.45

Calls 4

newFunction · 0.85
collectMethod · 0.80
into_iterMethod · 0.45
mapMethod · 0.45

Tested by

no test coverage detected