Skip to content

Commit 45dcc07

Browse files
committed
Register cache from cachemanager at listing table
1 parent d839d7a commit 45dcc07

1 file changed

Lines changed: 3 additions & 1 deletion

File tree

  • datafusion/core/src/execution/context

datafusion/core/src/execution/context/mod.rs

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1761,7 +1761,9 @@ impl SessionContext {
17611761
let config = ListingTableConfig::new(table_path)
17621762
.with_listing_options(options)
17631763
.with_schema(resolved_schema);
1764-
let table = ListingTable::try_new(config)?.with_definition(sql_definition);
1764+
let table = ListingTable::try_new(config)?.with_definition(sql_definition).with_cache(
1765+
self.runtime_env().cache_manager.get_file_statistic_cache()
1766+
);
17651767
self.register_table(table_ref, Arc::new(table))?;
17661768
Ok(())
17671769
}

0 commit comments

Comments
 (0)