@@ -46,11 +46,11 @@ async fn main() -> Result<()> {
46
46
47
47
let ctx = SessionContext :: new ( ) ;
48
48
let state = ctx. state ( ) ;
49
- let catlist = Arc :: new ( CustomCatalogProviderList :: new ( ) ) ;
49
+ let cataloglist = Arc :: new ( CustomCatalogProviderList :: new ( ) ) ;
50
50
51
51
// use our custom catalog list for context. each context has a single catalog list.
52
52
// context will by default have [`MemoryCatalogProviderList`]
53
- ctx. register_catalog_list ( catlist . clone ( ) ) ;
53
+ ctx. register_catalog_list ( cataloglist . clone ( ) ) ;
54
54
55
55
// initialize our catalog and schemas
56
56
let catalog = DirCatalog :: new ( ) ;
@@ -81,7 +81,7 @@ async fn main() -> Result<()> {
81
81
ctx. register_catalog ( "dircat" , Arc :: new ( catalog) ) ;
82
82
{
83
83
// catalog was passed down into our custom catalog list since we override the ctx's default
84
- let catalogs = catlist . catalogs . read ( ) . unwrap ( ) ;
84
+ let catalogs = cataloglist . catalogs . read ( ) . unwrap ( ) ;
85
85
assert ! ( catalogs. contains_key( "dircat" ) ) ;
86
86
} ;
87
87
@@ -143,8 +143,8 @@ impl DirSchema {
143
143
async fn create ( state : & SessionState , opts : DirSchemaOpts < ' _ > ) -> Result < Arc < Self > > {
144
144
let DirSchemaOpts { ext, dir, format } = opts;
145
145
let mut tables = HashMap :: new ( ) ;
146
- let listdir = std:: fs:: read_dir ( dir) . unwrap ( ) ;
147
- for res in listdir {
146
+ let direntries = std:: fs:: read_dir ( dir) . unwrap ( ) ;
147
+ for res in direntries {
148
148
let entry = res. unwrap ( ) ;
149
149
let filename = entry. file_name ( ) . to_str ( ) . unwrap ( ) . to_string ( ) ;
150
150
if !filename. ends_with ( ext) {
0 commit comments