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

Method run

datafusion-examples/examples/data_io/main.rs:103–134  ·  view source on GitHub ↗
(&self)

Source from the content-addressed store, hash-verified

101 }
102
103 async fn run(&self) -> Result<()> {
104 match self {
105 ExampleKind::All => {
106 for example in ExampleKind::runnable() {
107 println!("Running example: {example}");
108 Box::pin(example.run()).await?;
109 }
110 }
111 ExampleKind::Catalog => catalog::catalog().await?,
112 ExampleKind::InMemoryObjectStore => {
113 in_memory_object_store::in_memory_object_store().await?
114 }
115 ExampleKind::JsonShredding => json_shredding::json_shredding().await?,
116 ExampleKind::ParquetAdvIdx => {
117 parquet_advanced_index::parquet_advanced_index().await?
118 }
119 ExampleKind::ParquetEmbIdx => {
120 parquet_embedded_index::parquet_embedded_index().await?
121 }
122 ExampleKind::ParquetEncWithKms => {
123 parquet_encrypted_with_kms::parquet_encrypted_with_kms().await?
124 }
125 ExampleKind::ParquetEnc => parquet_encrypted::parquet_encrypted().await?,
126 ExampleKind::ParquetExecVisitor => {
127 parquet_exec_visitor::parquet_exec_visitor().await?
128 }
129 ExampleKind::ParquetIdx => parquet_index::parquet_index().await?,
130 ExampleKind::QueryHttpCsv => query_http_csv::query_http_csv().await?,
131 ExampleKind::RemoteCatalog => remote_catalog::remote_catalog().await?,
132 }
133 Ok(())
134 }
135}
136
137#[tokio::main]

Callers 1

mainFunction · 0.45

Calls 11

catalogFunction · 0.85
in_memory_object_storeFunction · 0.85
json_shreddingFunction · 0.85
parquet_advanced_indexFunction · 0.85
parquet_embedded_indexFunction · 0.85
parquet_encryptedFunction · 0.85
parquet_exec_visitorFunction · 0.85
parquet_indexFunction · 0.85
query_http_csvFunction · 0.85
remote_catalogFunction · 0.85

Tested by

no test coverage detected