Update for arrow 36

apache · Mar 22, 2023 · 7f16660 · 7f16660
1 parent ef89e1b
commit 7f16660
Show file tree

Hide file tree

Showing 17 changed files with 141 additions and 174 deletions.
diff --git a/Cargo.toml b/Cargo.toml
@@ -45,10 +45,10 @@ repository = "https://github.com/apache/arrow-datafusion"
 rust-version = "1.64"
 
 [workspace.dependencies]
-arrow = { version = "34.0.0", features = ["prettyprint"] }
-arrow-buffer = "34.0.0"
-arrow-schema = "34.0.0"
-parquet = { version = "34.0.0", features = ["arrow", "async"] }
+arrow = { version = "35.0.0", features = ["prettyprint"] }
+arrow-buffer = "35.0.0"
+arrow-schema = "35.0.0"
+parquet = { version = "35.0.0", features = ["arrow", "async"] }
 
 [profile.release]
 codegen-units = 1
@@ -67,3 +67,10 @@ opt-level = 3
 overflow-checks = false
 panic = 'unwind'
 rpath = false
+
+[patch.crates-io]
+arrow = { git = "https://github.com/apache/arrow-rs.git", rev = "a498a0342a15a7ddfa10c17752b0cc258bd80afd" }
+arrow-flight = { git = "https://github.com/apache/arrow-rs.git", rev = "a498a0342a15a7ddfa10c17752b0cc258bd80afd" }
+arrow-schema = { git = "https://github.com/apache/arrow-rs.git", rev = "a498a0342a15a7ddfa10c17752b0cc258bd80afd" }
+arrow-buffer = { git = "https://github.com/apache/arrow-rs.git", rev = "a498a0342a15a7ddfa10c17752b0cc258bd80afd" }
+parquet = { git = "https://github.com/apache/arrow-rs.git", rev = "a498a0342a15a7ddfa10c17752b0cc258bd80afd" }
diff --git a/benchmarks/src/bin/tpch.rs b/benchmarks/src/bin/tpch.rs
@@ -162,11 +162,11 @@ async fn main() -> Result<()> {
             let compression = match opt.compression.as_str() {
                 "none" => Compression::UNCOMPRESSED,
                 "snappy" => Compression::SNAPPY,
-                "brotli" => Compression::BROTLI,
-                "gzip" => Compression::GZIP,
+                "brotli" => Compression::BROTLI(Default::default()),
+                "gzip" => Compression::GZIP(Default::default()),
                 "lz4" => Compression::LZ4,
                 "lz0" => Compression::LZO,
-                "zstd" => Compression::ZSTD,
+                "zstd" => Compression::ZSTD(Default::default()),
                 other => {
                     return Err(DataFusionError::NotImplemented(format!(
                         "Invalid compression format: {other}"