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

Method execute

datafusion/catalog/src/information_schema.rs:602–613  ·  view source on GitHub ↗
(&self, _ctx: Arc<TaskContext>)

Source from the content-addressed store, hash-verified

600 }
601
602 fn execute(&self, _ctx: Arc<TaskContext>) -> SendableRecordBatchStream {
603 let mut builder = self.builder();
604 let config = self.config.clone();
605 Box::pin(RecordBatchStreamAdapter::new(
606 Arc::clone(&self.schema),
607 // TODO: Stream this
608 futures::stream::once(async move {
609 config.make_tables(&mut builder).await?;
610 Ok(builder.finish())
611 }),
612 ))
613 }
614}
615
616/// Builds the `information_schema.TABLE` table row by row

Callers

nothing calls this directly

Calls 15

newFunction · 0.85
make_tablesMethod · 0.80
make_viewsMethod · 0.80
make_columnsMethod · 0.80
make_schemataMethod · 0.80
make_df_settingsMethod · 0.80
session_configMethod · 0.80
make_routinesMethod · 0.80
make_parametersMethod · 0.80
builderMethod · 0.45
cloneMethod · 0.45
finishMethod · 0.45

Tested by

no test coverage detected