Usability impovements

.gitignore

@@ -2,3 +2,4 @@
 local-*
 /target
 Cargo.lock
+.vscode

Cargo.toml

@@ -23,16 +23,16 @@ blocking = ["reqwest/blocking"]
 
 [dependencies]
 tokio = { version = "1", features = ["macros", "rt-multi-thread",] }
-parquet = "14.0.0"
-reqwest = { version = "0.11", features = ["json"] }
+parquet = "52.1.0"
+reqwest = { version = "0.12", features = ["json"] }
 url = "2.2"
 rustc_version_runtime = "0.1"
 serde = { version = "1.0", features = ["derive"] }
 serde_json = "1.0"
 anyhow = "1.0"
 log = "0.4"
 env_logger = "0.9"
-polars = { version = "0.22.8", features = ["lazy", "parquet"] }
+polars = { version = "0.41.3", features = ["lazy", "parquet"] }
 
 [dev-dependencies]
 wiremock = "0.5"

examples/async.rs

@@ -11,7 +11,7 @@ async fn main() {
 
     let conf_str = &fs::read_to_string("./config.json").unwrap();
     let config: ProviderConfig = serde_json::from_str(conf_str).expect("Invalid configuration");
-    let mut app = Client::new(config, None).await.unwrap();
+    let mut app = Client::new(config, None, None).await.unwrap();
     let shares = app.list_shares().await.unwrap();
     if shares.len() == 0 {
         println!("At least 1 Delta Share is required");
@@ -42,7 +42,7 @@ async fn main() {
             );
         } else {
             let res = app
-                .get_dataframe(&tables[0])
+                .get_dataframe(&tables[0], None)
                 .await
                 .unwrap()
                 .collect()

examples/blocking.rs

@@ -10,7 +10,7 @@ fn main() {
     let conf_str = &fs::read_to_string("./config.json").unwrap();
 
     let config: ProviderConfig = serde_json::from_str(conf_str).expect("Invalid configuration");
-    let mut app = Client::new(config, None).unwrap();
+    let mut app = Client::new(config, None, None).unwrap();
     let shares = app.list_shares().unwrap();
     if shares.len() == 0 {
         println!("At least 1 Delta Share is required");
@@ -22,7 +22,11 @@ fn main() {
                 shares[0].name
             );
         } else {
-            let res = app.get_dataframe(&tables[0]).unwrap().collect().unwrap();
+            let res = app
+                .get_dataframe(&tables[0], None)
+                .unwrap()
+                .collect()
+                .unwrap();
             println!("Dataframe:\n {}", res);
         }
     }