This is an automated email from the ASF dual-hosted git repository.
piotr pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iggy.git
The following commit(s) were added to refs/heads/master by this push:
new b26246252 deps(connectors): Update iceberg to 0.8.0 (#2605)
b26246252 is described below
commit b26246252502ba6f5d6cad2895e7c468d9f959e4
Author: Edgar Modesto <[email protected]>
AuthorDate: Mon Jan 26 22:08:22 2026 -0700
deps(connectors): Update iceberg to 0.8.0 (#2605)
This PR fixes #2604 by upgrading iceberg-rust from 0.6.0 to 0.8.0.
The Iceberg connector was using an outdated version, and newer releases
introduced breaking changes and deprecations.
This update migrates the connector implementation to the 0.8.0 API.
---
Cargo.lock | 526 +++++++++------------
Cargo.toml | 13 +-
DEPENDENCIES.md | 124 +++--
core/connectors/sinks/iceberg_sink/src/catalog.rs | 37 +-
.../sinks/iceberg_sink/src/router/mod.rs | 41 +-
5 files changed, 354 insertions(+), 387 deletions(-)
diff --git a/Cargo.lock b/Cargo.lock
index 24d5d02d8..c8894b31d 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -205,7 +205,7 @@ dependencies = [
"serde_json",
"serde_urlencoded",
"smallvec",
- "socket2 0.6.1",
+ "socket2 0.6.2",
"time",
"tracing",
"url",
@@ -229,12 +229,6 @@ version = "2.0.1"
source = "registry+https://github.com/rust-lang/crates.io-index";
checksum = "320119579fcad9c21884f5c4861d16174d0e06250625266f50fe6898340abefa"
-[[package]]
-name = "adler32"
-version = "1.2.0"
-source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "aae1277d39aeec15cb388266ecc24b11c80469deae6067e17a1a7aa9e5c1f234"
-
[[package]]
name = "aead"
version = "0.5.2"
@@ -393,26 +387,27 @@ checksum =
"a23eb6b1614318a8071c9b2521f36b424b2c83db5eb3a0fead4a6c0809af6e61"
[[package]]
name = "apache-avro"
-version = "0.17.0"
+version = "0.21.0"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "1aef82843a0ec9f8b19567445ad2421ceeb1d711514384bdd3d49fe37102ee13"
+checksum = "36fa98bc79671c7981272d91a8753a928ff6a1cd8e4f20a44c45bd5d313840bf"
dependencies = [
"bigdecimal",
+ "bon",
"digest",
- "libflate",
"log",
+ "miniz_oxide",
"num-bigint",
"quad-rand",
- "rand 0.8.5",
+ "rand 0.9.2",
"regex-lite",
"serde",
"serde_bytes",
"serde_json",
- "strum 0.26.3",
- "strum_macros 0.26.4",
- "thiserror 1.0.69",
- "typed-builder 0.19.1",
+ "strum",
+ "strum_macros",
+ "thiserror 2.0.18",
"uuid",
+ "zstd",
]
[[package]]
@@ -456,23 +451,23 @@ checksum =
"7c02d123df017efcdfbd739ef81735b36c5ba83ec3c59c80a9d7ecc718f92e50"
[[package]]
name = "arrow-arith"
-version = "55.2.0"
+version = "57.2.0"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "30feb679425110209ae35c3fbf82404a39a4c0436bb3ec36164d8bffed2a4ce4"
+checksum = "288015089e7931843c80ed4032c5274f02b37bcb720c4a42096d50b390e70372"
dependencies = [
"arrow-array",
"arrow-buffer",
"arrow-data",
"arrow-schema",
"chrono",
- "num",
+ "num-traits",
]
[[package]]
name = "arrow-array"
-version = "55.2.0"
+version = "57.2.0"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "70732f04d285d49054a48b72c54f791bb3424abae92d27aafdf776c98af161c8"
+checksum = "65ca404ea6191e06bf30956394173337fa9c35f445bd447fe6c21ab944e1a23c"
dependencies = [
"ahash 0.8.12",
"arrow-buffer",
@@ -480,30 +475,34 @@ dependencies = [
"arrow-schema",
"chrono",
"half",
- "hashbrown 0.15.5",
- "num",
+ "hashbrown 0.16.1",
+ "num-complex",
+ "num-integer",
+ "num-traits",
]
[[package]]
name = "arrow-buffer"
-version = "55.2.0"
+version = "57.2.0"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "169b1d5d6cb390dd92ce582b06b23815c7953e9dfaaea75556e89d890d19993d"
+checksum = "36356383099be0151dacc4245309895f16ba7917d79bdb71a7148659c9206c56"
dependencies = [
"bytes",
"half",
- "num",
+ "num-bigint",
+ "num-traits",
]
[[package]]
name = "arrow-cast"
-version = "55.2.0"
+version = "57.2.0"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "e4f12eccc3e1c05a766cafb31f6a60a46c2f8efec9b74c6e0648766d30686af8"
+checksum = "9c8e372ed52bd4ee88cc1e6c3859aa7ecea204158ac640b10e187936e7e87074"
dependencies = [
"arrow-array",
"arrow-buffer",
"arrow-data",
+ "arrow-ord",
"arrow-schema",
"arrow-select",
"atoi",
@@ -511,40 +510,42 @@ dependencies = [
"chrono",
"half",
"lexical-core",
- "num",
+ "num-traits",
"ryu",
]
[[package]]
name = "arrow-data"
-version = "55.2.0"
+version = "57.2.0"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "8de1ce212d803199684b658fc4ba55fb2d7e87b213de5af415308d2fee3619c2"
+checksum = "bf87f4ff5fc13290aa47e499a8b669a82c5977c6a1fedce22c7f542c1fd5a597"
dependencies = [
"arrow-buffer",
"arrow-schema",
"half",
- "num",
+ "num-integer",
+ "num-traits",
]
[[package]]
name = "arrow-ipc"
-version = "55.2.0"
+version = "57.2.0"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "d9ea5967e8b2af39aff5d9de2197df16e305f47f404781d3230b2dc672da5d92"
+checksum = "eb3ca63edd2073fcb42ba112f8ae165df1de935627ead6e203d07c99445f2081"
dependencies = [
"arrow-array",
"arrow-buffer",
"arrow-data",
"arrow-schema",
+ "arrow-select",
"flatbuffers",
]
[[package]]
name = "arrow-json"
-version = "55.2.0"
+version = "57.2.0"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "5709d974c4ea5be96d900c01576c7c0b99705f4a3eec343648cb1ca863988a9c"
+checksum = "a36b2332559d3310ebe3e173f75b29989b4412df4029a26a30cc3f7da0869297"
dependencies = [
"arrow-array",
"arrow-buffer",
@@ -554,19 +555,21 @@ dependencies = [
"chrono",
"half",
"indexmap 2.13.0",
+ "itoa",
"lexical-core",
"memchr",
- "num",
- "serde",
+ "num-traits",
+ "ryu",
+ "serde_core",
"serde_json",
"simdutf8",
]
[[package]]
name = "arrow-ord"
-version = "55.2.0"
+version = "57.2.0"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "6506e3a059e3be23023f587f79c82ef0bcf6d293587e3272d20f2d30b969b5a7"
+checksum = "13c4e0530272ca755d6814218dffd04425c5b7854b87fa741d5ff848bf50aa39"
dependencies = [
"arrow-array",
"arrow-buffer",
@@ -577,29 +580,29 @@ dependencies = [
[[package]]
name = "arrow-schema"
-version = "55.2.0"
+version = "57.2.0"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "af7686986a3bf2254c9fb130c623cdcb2f8e1f15763e7c71c310f0834da3d292"
+checksum = "6bb63203e8e0e54b288d0d8043ca8fa1013820822a27692ef1b78a977d879f2c"
[[package]]
name = "arrow-select"
-version = "55.2.0"
+version = "57.2.0"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "dd2b45757d6a2373faa3352d02ff5b54b098f5e21dccebc45a21806bc34501e5"
+checksum = "c96d8a1c180b44ecf2e66c9a2f2bbcb8b1b6f14e165ce46ac8bde211a363411b"
dependencies = [
"ahash 0.8.12",
"arrow-array",
"arrow-buffer",
"arrow-data",
"arrow-schema",
- "num",
+ "num-traits",
]
[[package]]
name = "arrow-string"
-version = "55.2.0"
+version = "57.2.0"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "0377d532850babb4d927a06294314b316e23311503ed580ec6ce6a0158f49d40"
+checksum = "a8ad6a81add9d3ea30bf8374ee8329992c7fd246ffd8b7e2f48a3cea5aa0cc9a"
dependencies = [
"arrow-array",
"arrow-buffer",
@@ -607,7 +610,7 @@ dependencies = [
"arrow-schema",
"arrow-select",
"memchr",
- "num",
+ "num-traits",
"regex",
"regex-syntax",
]
@@ -630,7 +633,7 @@ dependencies = [
"nom 7.1.3",
"num-traits",
"rusticata-macros",
- "thiserror 2.0.17",
+ "thiserror 2.0.18",
"time",
]
@@ -835,7 +838,7 @@ dependencies = [
"crc32fast",
"futures-lite",
"pin-project",
- "thiserror 2.0.17",
+ "thiserror 2.0.18",
"tokio",
"tokio-util",
]
@@ -890,9 +893,9 @@ dependencies = [
[[package]]
name = "aws-lc-rs"
-version = "1.15.2"
+version = "1.15.4"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "6a88aab2464f1f25453baa7a07c84c5b7684e274054ba06817f382357f77a288"
+checksum = "7b7b6141e96a8c160799cc2d5adecd5cbbe5054cb8c7c4af53da0f83bb7ad256"
dependencies = [
"aws-lc-sys",
"zeroize",
@@ -900,9 +903,9 @@ dependencies = [
[[package]]
name = "aws-lc-sys"
-version = "0.35.0"
+version = "0.37.0"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "b45afffdee1e7c9126814751f88dddc747f41d91da16c9551a0f1e8a11e788a1"
+checksum = "5c34dda4df7017c8db52132f0f8a2e0f8161649d15723ed63fc00c82d0f2081a"
dependencies = [
"cc",
"cmake",
@@ -1060,7 +1063,7 @@ dependencies = [
"gloo",
"js-sys",
"serde_json",
- "thiserror 2.0.17",
+ "thiserror 2.0.18",
"uuid",
"wasm-bindgen",
"web-sys",
@@ -1258,7 +1261,7 @@ dependencies = [
"serde_json",
"serde_repr",
"serde_urlencoded",
- "thiserror 2.0.17",
+ "thiserror 2.0.18",
"tokio",
"tokio-stream",
"tokio-util",
@@ -1490,14 +1493,14 @@ dependencies = [
"semver",
"serde",
"serde_json",
- "thiserror 2.0.17",
+ "thiserror 2.0.18",
]
[[package]]
name = "cc"
-version = "1.2.52"
+version = "1.2.54"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "cd4932aefd12402b36c60956a4fe0035421f544799057659ff86f923657aada3"
+checksum = "6354c81bbfd62d9cfa9cb3c773c2b7b2a3a482d569de977fd0e961f6e7c00583"
dependencies = [
"find-msvc-tools",
"jobserver",
@@ -1647,7 +1650,7 @@ version = "0.3.0"
source = "registry+https://github.com/rust-lang/crates.io-index";
checksum = "0fa961b519f0b462e3a3b4a34b64d119eeaca1d59af726fe450bbba07a9fc0a1"
dependencies = [
- "thiserror 2.0.17",
+ "thiserror 2.0.18",
]
[[package]]
@@ -1736,7 +1739,7 @@ dependencies = [
"paste",
"polling",
"slab",
- "socket2 0.6.1",
+ "socket2 0.6.2",
"windows-sys 0.61.2",
]
@@ -1804,7 +1807,7 @@ dependencies = [
"either",
"libc",
"once_cell",
- "socket2 0.6.1",
+ "socket2 0.6.2",
"widestring",
"windows-sys 0.61.2",
]
@@ -1827,7 +1830,7 @@ dependencies = [
"quinn-proto",
"rustc-hash",
"rustls",
- "thiserror 2.0.17",
+ "thiserror 2.0.18",
"windows-sys 0.61.2",
]
@@ -1850,7 +1853,7 @@ dependencies = [
"pin-project-lite",
"scoped-tls",
"slab",
- "socket2 0.6.1",
+ "socket2 0.6.2",
"windows-sys 0.61.2",
]
@@ -2022,15 +2025,6 @@ version = "0.8.7"
source = "registry+https://github.com/rust-lang/crates.io-index";
checksum = "773648b94d0e5d620f64f280777445740e61fe701025087ec8b57f45c791888b"
-[[package]]
-name = "core2"
-version = "0.4.0"
-source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "b49ba7ef1ad6107f8824dbe97de947cbaac53c44e7f9756a1fba0d37c1eec505"
-dependencies = [
- "memchr",
-]
-
[[package]]
name = "core_affinity"
version = "0.8.3"
@@ -2340,7 +2334,7 @@ dependencies = [
"send_wrapper",
"serde",
"serde_urlencoded",
- "thiserror 2.0.17",
+ "thiserror 2.0.18",
"tower-service",
"url",
]
@@ -2360,7 +2354,7 @@ dependencies = [
"hyper",
"hyper-util",
"send_wrapper",
- "socket2 0.6.1",
+ "socket2 0.6.2",
"tokio",
"tower",
"tower-service",
@@ -2482,12 +2476,6 @@ dependencies = [
"syn 2.0.114",
]
-[[package]]
-name = "dary_heap"
-version = "0.3.8"
-source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "06d2e3287df1c007e74221c49ca10a95d557349e54b3a75dc2fb14712c751f04"
-
[[package]]
name = "dashmap"
version = "6.1.0"
@@ -3163,30 +3151,29 @@ dependencies = [
[[package]]
name = "file-operation"
-version = "0.8.11"
+version = "0.8.17"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "42c2d0511147e9c5aebb94162f9c90aaeb1c232dcd8f864654d30edfbf0385bc"
+checksum = "26c0631d03bfea8182f9d0ab12f3d0d8d9aeac38c2a738b18d97b59a0c1eae67"
dependencies = [
"tokio",
]
[[package]]
name = "filetime"
-version = "0.2.26"
+version = "0.2.27"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "bc0505cd1b6fa6580283f6bdf70a73fcf4aba1184038c90902b92b3dd0df63ed"
+checksum = "f98844151eee8917efc50bd9e8318cb963ae8b297431495d3f758616ea5c57db"
dependencies = [
"cfg-if",
"libc",
"libredox",
- "windows-sys 0.60.2",
]
[[package]]
name = "find-msvc-tools"
-version = "0.1.7"
+version = "0.1.8"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "f449e6c6c08c865631d4890cfacf252b3d396c9bcc83adb6623cdb02a8336c41"
+checksum = "8591b0bcc8a98a64310a2fae1bb3e9b8564dd10e381e6e28010fde8e8e8568db"
[[package]]
name = "flatbuffers"
@@ -3526,7 +3513,7 @@ dependencies = [
"serde_json",
"syn 2.0.114",
"textwrap",
- "thiserror 2.0.17",
+ "thiserror 2.0.18",
"typed-builder 0.23.2",
]
@@ -3858,7 +3845,7 @@ dependencies = [
"pest_derive",
"serde",
"serde_json",
- "thiserror 2.0.17",
+ "thiserror 2.0.18",
]
[[package]]
@@ -4078,8 +4065,8 @@ dependencies = [
"errno",
"hwlocality-sys",
"libc",
- "strum 0.27.2",
- "thiserror 2.0.17",
+ "strum",
+ "thiserror 2.0.18",
"windows-sys 0.61.2",
]
@@ -4188,7 +4175,7 @@ dependencies = [
"libc",
"percent-encoding",
"pin-project-lite",
- "socket2 0.6.1",
+ "socket2 0.6.2",
"tokio",
"tower-service",
"tracing",
@@ -4235,9 +4222,9 @@ dependencies = [
[[package]]
name = "iceberg"
-version = "0.6.0"
+version = "0.8.0"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "306fd4bf70d30687dc765110ecd19fc2bb21f16c3d5c188bc53a0d573bb6e675"
+checksum = "e65918e701cf610ab0cea57f7f31db5bf4f973230c2c160244067bce01f7c5fa"
dependencies = [
"anyhow",
"apache-avro",
@@ -4259,6 +4246,7 @@ dependencies = [
"chrono",
"derive_builder",
"expect-test",
+ "flate2",
"fnv",
"futures",
"itertools 0.13.0",
@@ -4270,6 +4258,7 @@ dependencies = [
"ordered-float 4.6.0",
"parquet",
"rand 0.8.5",
+ "reqsign",
"reqwest",
"roaring",
"rust_decimal",
@@ -4279,8 +4268,7 @@ dependencies = [
"serde_json",
"serde_repr",
"serde_with",
- "strum 0.27.2",
- "thrift",
+ "strum",
"tokio",
"typed-builder 0.20.1",
"url",
@@ -4290,9 +4278,9 @@ dependencies = [
[[package]]
name = "iceberg-catalog-rest"
-version = "0.6.0"
+version = "0.8.0"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "3e6a0dc30703b0cbb7d3c245126936d92015f93ab3ac52e20edc011f42934628"
+checksum = "d6d5e120317ab88a3af332c17166aad101f2aee9bfb098d63d4525bdd5cc2da7"
dependencies = [
"async-trait",
"chrono",
@@ -4496,7 +4484,7 @@ dependencies = [
"serde",
"serde_json",
"tempfile",
- "thiserror 2.0.17",
+ "thiserror 2.0.18",
"tokio",
"tracing",
"tracing-subscriber",
@@ -4518,7 +4506,7 @@ dependencies = [
"iggy_binary_protocol",
"keyring",
"passterm",
- "thiserror 2.0.17",
+ "thiserror 2.0.18",
"tokio",
"tracing",
"tracing-appender",
@@ -4562,9 +4550,9 @@ dependencies = [
"serde_json",
"serde_with",
"serde_yaml_ng",
- "strum 0.27.2",
+ "strum",
"tempfile",
- "thiserror 2.0.17",
+ "thiserror 2.0.18",
"tokio",
"toml 0.9.11+spec-1.1.0",
"tower-http",
@@ -4594,9 +4582,9 @@ dependencies = [
"rmcp",
"serde",
"serde_json",
- "strum 0.27.2",
+ "strum",
"tempfile",
- "thiserror 2.0.17",
+ "thiserror 2.0.18",
"tokio",
"tower-http",
"tracing",
@@ -4660,8 +4648,8 @@ dependencies = [
"serde_json",
"serde_with",
"serial_test",
- "strum 0.27.2",
- "thiserror 2.0.17",
+ "strum",
+ "thiserror 2.0.18",
"tokio",
"toml 0.9.11+spec-1.1.0",
"tracing",
@@ -4719,7 +4707,7 @@ dependencies = [
"parquet",
"serde",
"simd-json",
- "strum 0.27.2",
+ "strum",
"tracing",
"uuid",
]
@@ -4816,8 +4804,8 @@ dependencies = [
"serde",
"serde_json",
"simd-json",
- "strum_macros 0.27.2",
- "thiserror 2.0.17",
+ "strum_macros",
+ "thiserror 2.0.18",
"tokio",
"tracing",
"tracing-subscriber",
@@ -4851,7 +4839,7 @@ dependencies = [
"rand 0.9.2",
"serde",
"serde_json",
- "thiserror 2.0.17",
+ "thiserror 2.0.18",
"tokio",
"tracing",
"tracing-subscriber",
@@ -5001,8 +4989,8 @@ dependencies = [
"serial_test",
"server",
"sqlx",
- "strum 0.27.2",
- "strum_macros 0.27.2",
+ "strum",
+ "strum_macros",
"tempfile",
"test-case",
"testcontainers-modules",
@@ -5096,10 +5084,12 @@ source =
"registry+https://github.com/rust-lang/crates.io-index";
checksum = "e67e8da4c49d6d9909fe03361f9b620f58898859f5c7aded68351e85e71ecf50"
dependencies = [
"jiff-static",
+ "jiff-tzdb-platform",
"log",
"portable-atomic",
"portable-atomic-util",
"serde_core",
+ "windows-sys 0.61.2",
]
[[package]]
@@ -5113,6 +5103,21 @@ dependencies = [
"syn 2.0.114",
]
+[[package]]
+name = "jiff-tzdb"
+version = "0.1.5"
+source = "registry+https://github.com/rust-lang/crates.io-index";
+checksum = "68971ebff725b9e2ca27a601c5eb38a4c5d64422c4cbab0c535f248087eda5c2"
+
+[[package]]
+name = "jiff-tzdb-platform"
+version = "0.1.3"
+source = "registry+https://github.com/rust-lang/crates.io-index";
+checksum = "875a5a69ac2bab1a891711cf5eccbec1ce0341ea805560dcd90b7a2e925132e8"
+dependencies = [
+ "jiff-tzdb",
+]
+
[[package]]
name = "jni"
version = "0.21.1"
@@ -5151,9 +5156,9 @@ version = "0.1.0"
[[package]]
name = "js-sys"
-version = "0.3.83"
+version = "0.3.85"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "464a3709c7f55f1f721e5389aa6ea4e3bc6aba669353300af094b29ffbdde1d8"
+checksum = "8c942ebf8e95485ca0d52d97da7c5a2c387d0e7f0ba4c35e93bfcaee045955b3"
dependencies = [
"once_cell",
"wasm-bindgen",
@@ -5363,30 +5368,6 @@ dependencies = [
"pkg-config",
]
-[[package]]
-name = "libflate"
-version = "2.2.1"
-source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "e3248b8d211bd23a104a42d81b4fa8bb8ac4a3b75e7a43d85d2c9ccb6179cd74"
-dependencies = [
- "adler32",
- "core2",
- "crc32fast",
- "dary_heap",
- "libflate_lz77",
-]
-
-[[package]]
-name = "libflate_lz77"
-version = "2.2.0"
-source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "a599cb10a9cd92b1300debcef28da8f70b935ec937f44fcd1b70a7c986a11c5c"
-dependencies = [
- "core2",
- "hashbrown 0.16.1",
- "rle-decode-fast",
-]
-
[[package]]
name = "libgit2-sys"
version = "0.18.3+1.9.2"
@@ -5410,9 +5391,9 @@ dependencies = [
[[package]]
name = "liblzma-sys"
-version = "0.4.4"
+version = "0.4.5"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "01b9596486f6d60c3bbe644c0e1be1aa6ccc472ad630fe8927b456973d7cb736"
+checksum = "9f2db66f3268487b5033077f266da6777d057949b8f93c8ad82e441df25e6186"
dependencies = [
"cc",
"libc",
@@ -5421,9 +5402,9 @@ dependencies = [
[[package]]
name = "libm"
-version = "0.2.15"
+version = "0.2.16"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "f9fbbcab51052fe104eb5e5d351cf728d30a5be1fe14d9be8a3b097481fb97de"
+checksum = "b6d2cec3eae94f9f509c767b45932f1ada8350c4bdb85af2fcab4a3c14807981"
[[package]]
name = "libmimalloc-sys"
@@ -5579,9 +5560,9 @@ checksum =
"112b39cec0b298b6c1999fee3e31427f74f676e4cb9879ed1a121b43661a4154"
[[package]]
name = "lz4_flex"
-version = "0.11.5"
+version = "0.12.0"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "08ab2867e3eeeca90e844d1940eab391c9dc5228783db2ed999acbc0a9ed375a"
+checksum = "ab6473172471198271ff72e9379150e9dfd70d8e533e0752a27e515b48dd375e"
dependencies = [
"twox-hash",
]
@@ -5759,9 +5740,9 @@ dependencies = [
[[package]]
name = "moka"
-version = "0.12.12"
+version = "0.12.13"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "a3dec6bd31b08944e08b58fd99373893a6c17054d6f3ea5006cc894f4f4eee2a"
+checksum = "b4ac832c50ced444ef6be0767a008b02c106a909ba79d1d830501e94b96f6b7e"
dependencies = [
"async-lock",
"crossbeam-channel",
@@ -5869,9 +5850,12 @@ dependencies = [
[[package]]
name = "notify-types"
-version = "2.0.0"
+version = "2.1.0"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "5e0826a989adedc2a244799e823aece04662b66609d96af8dff7ac6df9a8925d"
+checksum = "42b8cfee0e339a0337359f3c88165702ac6e600dc01c0cc9579a92d62b08477a"
+dependencies = [
+ "bitflags 2.10.0",
+]
[[package]]
name = "nougat"
@@ -5964,9 +5948,9 @@ dependencies = [
[[package]]
name = "num-conv"
-version = "0.1.0"
+version = "0.2.0"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "51d515d32fb182ee37cda2ccdcb92950d6a3c2893aa280e540671c2cd0f3b1d9"
+checksum = "cf97ec579c3c42f953ef76dbf8d55ac91fb219dde70e49aa4a6b7d74e9919050"
[[package]]
name = "num-integer"
@@ -6148,20 +6132,20 @@ checksum =
"c08d65885ee38876c4f86fa503fb49d7b507c2b62552df7c70b2fce627e06381"
[[package]]
name = "opendal"
-version = "0.54.1"
+version = "0.55.0"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "42afda58fa2cf50914402d132cc1caacff116a85d10c72ab2082bb7c50021754"
+checksum = "d075ab8a203a6ab4bc1bce0a4b9fe486a72bf8b939037f4b78d95386384bc80a"
dependencies = [
"anyhow",
"backon",
"base64 0.22.1",
"bytes",
- "chrono",
"crc32c",
"futures",
"getrandom 0.2.17",
"http 1.4.0",
"http-body",
+ "jiff",
"log",
"md-5",
"percent-encoding",
@@ -6171,6 +6155,7 @@ dependencies = [
"serde",
"serde_json",
"tokio",
+ "url",
"uuid",
]
@@ -6202,9 +6187,9 @@ dependencies = [
[[package]]
name = "openssl-probe"
-version = "0.2.0"
+version = "0.2.1"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "9f50d9b3dabb09ecd771ad0aa242ca6894994c130308ca3d7684634df8037391"
+checksum = "7c87def4c32ab89d880effc9e097653c8da5d6ef28e6b539d313baaacfbafcbe"
[[package]]
name = "openssl-src"
@@ -6238,7 +6223,7 @@ dependencies = [
"futures-sink",
"js-sys",
"pin-project-lite",
- "thiserror 2.0.17",
+ "thiserror 2.0.18",
"tracing",
]
@@ -6281,7 +6266,7 @@ dependencies = [
"opentelemetry_sdk",
"prost",
"reqwest",
- "thiserror 2.0.17",
+ "thiserror 2.0.18",
"tokio",
"tonic",
"tracing",
@@ -6318,7 +6303,7 @@ dependencies = [
"opentelemetry",
"percent-encoding",
"rand 0.9.2",
- "thiserror 2.0.17",
+ "thiserror 2.0.18",
"tokio",
"tokio-stream",
]
@@ -6432,9 +6417,9 @@ dependencies = [
[[package]]
name = "parquet"
-version = "55.2.0"
+version = "57.2.0"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "b17da4150748086bd43352bc77372efa9b6e3dbd06a04831d2a98c041c225cfa"
+checksum = "5f6a2926a30477c0b95fea6c28c3072712b139337a242c2cc64817bdc20a8854"
dependencies = [
"ahash 0.8.12",
"arrow-array",
@@ -6451,10 +6436,11 @@ dependencies = [
"flate2",
"futures",
"half",
- "hashbrown 0.15.5",
+ "hashbrown 0.16.1",
"lz4_flex",
- "num",
"num-bigint",
+ "num-integer",
+ "num-traits",
"paste",
"seq-macro",
"simdutf8",
@@ -6896,9 +6882,9 @@ dependencies = [
[[package]]
name = "proc-macro2"
-version = "1.0.105"
+version = "1.0.106"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "535d180e0ecab6268a3e718bb9fd44db66bbbc256257165fc699dadf70d16fe7"
+checksum = "8fd00f0bb2e90d81d1044c2b32617f68fcb9fa3bb7640c23e9c748e53fb30934"
dependencies = [
"unicode-ident",
]
@@ -6995,7 +6981,7 @@ dependencies = [
"prost-reflect",
"prost-types",
"protox-parse",
- "thiserror 2.0.17",
+ "thiserror 2.0.18",
]
[[package]]
@@ -7007,7 +6993,7 @@ dependencies = [
"logos",
"miette",
"prost-types",
- "thiserror 2.0.17",
+ "thiserror 2.0.18",
]
[[package]]
@@ -7084,8 +7070,8 @@ dependencies = [
"quinn-udp",
"rustc-hash",
"rustls",
- "socket2 0.6.1",
- "thiserror 2.0.17",
+ "socket2 0.6.2",
+ "thiserror 2.0.18",
"tokio",
"tracing",
"web-time",
@@ -7108,7 +7094,7 @@ dependencies = [
"rustls-pki-types",
"rustls-platform-verifier",
"slab",
- "thiserror 2.0.17",
+ "thiserror 2.0.18",
"tinyvec",
"tracing",
"web-time",
@@ -7123,16 +7109,16 @@ dependencies = [
"cfg_aliases",
"libc",
"once_cell",
- "socket2 0.6.1",
+ "socket2 0.6.2",
"tracing",
"windows-sys 0.60.2",
]
[[package]]
name = "quote"
-version = "1.0.43"
+version = "1.0.44"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "dc74d9a594b72ae6656596548f56f667211f8a97b3d4c3d467150794690dc40a"
+checksum = "21b2ebcf727b7760c461f091f9f0f539b77b8e87f2fd88131e7f1b433b3cece4"
dependencies = [
"proc-macro2",
]
@@ -7248,9 +7234,9 @@ dependencies = [
[[package]]
name = "rcgen"
-version = "0.14.6"
+version = "0.14.7"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "3ec0a99f2de91c3cddc84b37e7db80e4d96b743e05607f647eb236fc0455907f"
+checksum = "10b99e0098aa4082912d4c649628623db6aba77335e4f4569ff5083a6448b32e"
dependencies = [
"pem",
"ring",
@@ -7286,7 +7272,7 @@ checksum =
"a4e608c6638b9c18977b00b475ac1f28d14e84b27d8d42f70e0bf1e3dec127ac"
dependencies = [
"getrandom 0.2.17",
"libredox",
- "thiserror 2.0.17",
+ "thiserror 2.0.18",
]
[[package]]
@@ -7454,7 +7440,7 @@ dependencies = [
"reqwest",
"reqwest-middleware",
"retry-policies",
- "thiserror 2.0.17",
+ "thiserror 2.0.18",
"tokio",
"tracing",
"wasmtimer",
@@ -7544,12 +7530,6 @@ dependencies = [
"syn 1.0.109",
]
-[[package]]
-name = "rle-decode-fast"
-version = "1.0.3"
-source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "3582f63211428f83597b51b2ddb88e2a91a9d52d12831f9d08f5e624e8977422"
-
[[package]]
name = "rmcp"
version = "0.13.0"
@@ -7574,7 +7554,7 @@ dependencies = [
"serde",
"serde_json",
"sse-stream",
- "thiserror 2.0.17",
+ "thiserror 2.0.18",
"tokio",
"tokio-stream",
"tokio-util",
@@ -7617,9 +7597,9 @@ dependencies = [
[[package]]
name = "roaring"
-version = "0.10.12"
+version = "0.11.3"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "19e8d2cfa184d94d0726d650a9f4a1be7f9b76ac9fdb954219878dc00c1c1e7b"
+checksum = "8ba9ce64a8f45d7fc86358410bb1a82e8c987504c0d4900e9141d69a9f26c885"
dependencies = [
"bytemuck",
"byteorder",
@@ -7787,9 +7767,9 @@ dependencies = [
[[package]]
name = "rustls-pki-types"
-version = "1.13.2"
+version = "1.14.0"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "21e6f2ab2928ca4291b86736a8bd920a277a399bba1589409d72154ff87c1282"
+checksum = "be040f8b0a225e40375822a563fa9524378b9d63112f53e19ffff34df5d33fdd"
dependencies = [
"web-time",
"zeroize",
@@ -7824,9 +7804,9 @@ checksum =
"f87165f0995f63a9fbeea62b64d10b4d9d8e78ec6d7d51fb2125fda7bb36788f"
[[package]]
name = "rustls-webpki"
-version = "0.103.8"
+version = "0.103.9"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "2ffdfa2f5286e2247234e03f680868ac2815974dc39e00ea15adc445d0aafe52"
+checksum = "d7df23109aa6c1567d1c575b9952556388da57401e4ace1d15f79eedad0d8f53"
dependencies = [
"aws-lc-rs",
"ring",
@@ -8286,12 +8266,12 @@ dependencies = [
"serde",
"serde_with",
"slab",
- "socket2 0.6.1",
+ "socket2 0.6.2",
"static-toml",
- "strum 0.27.2",
+ "strum",
"sysinfo",
"tempfile",
- "thiserror 2.0.17",
+ "thiserror 2.0.18",
"tokio",
"toml 0.9.11+spec-1.1.0",
"tower-http",
@@ -8406,7 +8386,7 @@ checksum =
"297f631f50729c8c99b84667867963997ec0b50f32b2a7dbcab828ef0541e8bb"
dependencies = [
"num-bigint",
"num-traits",
- "thiserror 2.0.17",
+ "thiserror 2.0.18",
"time",
]
@@ -8487,9 +8467,9 @@ dependencies = [
[[package]]
name = "socket2"
-version = "0.6.1"
+version = "0.6.2"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "17129e116933cf371d018bb80ae557e889637989d8638274fb25622827b03881"
+checksum = "86f4aa3ad99f2088c990dfa82d367e19cb29268ed67c574d10d0a4bfe71f07e0"
dependencies = [
"libc",
"windows-sys 0.60.2",
@@ -8565,7 +8545,7 @@ dependencies = [
"serde_json",
"sha2",
"smallvec",
- "thiserror 2.0.17",
+ "thiserror 2.0.18",
"tokio",
"tokio-stream",
"tracing",
@@ -8650,7 +8630,7 @@ dependencies = [
"smallvec",
"sqlx-core",
"stringprep",
- "thiserror 2.0.17",
+ "thiserror 2.0.18",
"tracing",
"uuid",
"whoami",
@@ -8689,7 +8669,7 @@ dependencies = [
"smallvec",
"sqlx-core",
"stringprep",
- "thiserror 2.0.17",
+ "thiserror 2.0.18",
"tracing",
"uuid",
"whoami",
@@ -8715,7 +8695,7 @@ dependencies = [
"serde",
"serde_urlencoded",
"sqlx-core",
- "thiserror 2.0.17",
+ "thiserror 2.0.18",
"tracing",
"url",
"uuid",
@@ -8794,32 +8774,13 @@ dependencies = [
"syn 2.0.114",
]
-[[package]]
-name = "strum"
-version = "0.26.3"
-source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "8fec0f0aef304996cf250b31b5a10dee7980c85da9d759361292b8bca5a18f06"
-
[[package]]
name = "strum"
version = "0.27.2"
source = "registry+https://github.com/rust-lang/crates.io-index";
checksum = "af23d6f6c1a224baef9d3f61e287d2761385a5b88fdab4eb4c6f11aeb54c4bcf"
dependencies = [
- "strum_macros 0.27.2",
-]
-
-[[package]]
-name = "strum_macros"
-version = "0.26.4"
-source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "4c6bee85a5a24955dc440386795aa378cd9cf82acd5f764469152d2270e581be"
-dependencies = [
- "heck",
- "proc-macro2",
- "quote",
- "rustversion",
- "syn 2.0.114",
+ "strum_macros",
]
[[package]]
@@ -9037,7 +8998,7 @@ dependencies = [
"serde",
"serde_json",
"serde_with",
- "thiserror 2.0.17",
+ "thiserror 2.0.18",
"tokio",
"tokio-stream",
"tokio-util",
@@ -9075,11 +9036,11 @@ dependencies = [
[[package]]
name = "thiserror"
-version = "2.0.17"
+version = "2.0.18"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "f63587ca0f12b72a0600bcba1d40081f830876000bb46dd2337a3051618f4fc8"
+checksum = "4288b5bcbc7920c07a1149a35cf9590a2aa808e0bc1eafaade0b80947865fbc4"
dependencies = [
- "thiserror-impl 2.0.17",
+ "thiserror-impl 2.0.18",
]
[[package]]
@@ -9095,9 +9056,9 @@ dependencies = [
[[package]]
name = "thiserror-impl"
-version = "2.0.17"
+version = "2.0.18"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "3ff15c8ecd7de3849db632e14d18d2571fa09dfc5ed93479bc4485c7a517c913"
+checksum = "ebc4ee7f67670e9b64d05fa4253e753e016c6c95ff35b89b7941d6b856dec1d5"
dependencies = [
"proc-macro2",
"quote",
@@ -9113,15 +9074,6 @@ dependencies = [
"cfg-if",
]
-[[package]]
-name = "threadpool"
-version = "1.8.1"
-source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "d050e60b33d41c19108b32cea32164033a9013fe3b46cbd4457559bfbf77afaa"
-dependencies = [
- "num_cpus",
-]
-
[[package]]
name = "thrift"
version = "0.17.0"
@@ -9130,16 +9082,14 @@ checksum =
"7e54bc85fc7faa8bc175c4bab5b92ba8d9a3ce893d0e9f42cc455c8ab16a9e09"
dependencies = [
"byteorder",
"integer-encoding",
- "log",
"ordered-float 2.10.1",
- "threadpool",
]
[[package]]
name = "time"
-version = "0.3.45"
+version = "0.3.46"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "f9e442fc33d7fdb45aa9bfeb312c095964abdf596f7567261062b2a7107aaabd"
+checksum = "9da98b7d9b7dad93488a84b8248efc35352b0b2657397d4167e7ad67e5d535e5"
dependencies = [
"deranged",
"itoa",
@@ -9154,15 +9104,15 @@ dependencies = [
[[package]]
name = "time-core"
-version = "0.1.7"
+version = "0.1.8"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "8b36ee98fd31ec7426d599183e8fe26932a8dc1fb76ddb6214d05493377d34ca"
+checksum = "7694e1cfe791f8d31026952abf09c69ca6f6fa4e1a1229e18988f06a04a12dca"
[[package]]
name = "time-macros"
-version = "0.2.25"
+version = "0.2.26"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "71e552d1249bf61ac2a52db88179fd0673def1e1ad8243a00d9ec9ed71fee3dd"
+checksum = "78cc610bac2dcee56805c99642447d4c5dbde4d01f752ffea0199aee1f601dc4"
dependencies = [
"num-conv",
"time-core",
@@ -9214,7 +9164,7 @@ dependencies = [
"parking_lot",
"pin-project-lite",
"signal-hook-registry",
- "socket2 0.6.1",
+ "socket2 0.6.2",
"tokio-macros",
"windows-sys 0.61.2",
]
@@ -9420,7 +9370,7 @@ dependencies = [
"hyper-util",
"percent-encoding",
"pin-project",
- "socket2 0.6.1",
+ "socket2 0.6.2",
"sync_wrapper",
"tokio",
"tokio-stream",
@@ -9528,7 +9478,7 @@ source =
"registry+https://github.com/rust-lang/crates.io-index";
checksum = "786d480bce6247ab75f005b14ae1624ad978d3029d9113f0a22fa1ac773faeaf"
dependencies = [
"crossbeam-channel",
- "thiserror 2.0.17",
+ "thiserror 2.0.18",
"time",
"tracing-subscriber",
]
@@ -9631,7 +9581,7 @@ dependencies = [
"rustls",
"rustls-pki-types",
"sha1",
- "thiserror 2.0.17",
+ "thiserror 2.0.18",
"utf-8",
]
@@ -9644,15 +9594,6 @@ dependencies = [
"rand 0.9.2",
]
-[[package]]
-name = "typed-builder"
-version = "0.19.1"
-source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "a06fbd5b8de54c5f7c91f6fe4cebb949be2125d7758e630bb58b1d831dbce600"
-dependencies = [
- "typed-builder-macro 0.19.1",
-]
-
[[package]]
name = "typed-builder"
version = "0.20.1"
@@ -9671,17 +9612,6 @@ dependencies = [
"typed-builder-macro 0.23.2",
]
-[[package]]
-name = "typed-builder-macro"
-version = "0.19.1"
-source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "f9534daa9fd3ed0bd911d462a37f172228077e7abf18c18a5f67199d959205f8"
-dependencies = [
- "proc-macro2",
- "quote",
- "syn 2.0.114",
-]
-
[[package]]
name = "typed-builder-macro"
version = "0.20.1"
@@ -9704,6 +9634,12 @@ dependencies = [
"syn 2.0.114",
]
+[[package]]
+name = "typed-path"
+version = "0.12.1"
+source = "registry+https://github.com/rust-lang/crates.io-index";
+checksum = "e43ffa54726cdc9ea78392023ffe9fe9cf9ac779e1c6fcb0d23f9862e3879d20"
+
[[package]]
name = "typenum"
version = "1.19.0"
@@ -9894,9 +9830,9 @@ checksum =
"06abde3611657adf66d383f00b093d7faecc7fa57071cce2578660c9f1010821"
[[package]]
name = "uuid"
-version = "1.19.0"
+version = "1.20.0"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "e2e054861b4bd027cd373e18e8d8d8e6548085000e41290d95ce0c373a654b4a"
+checksum = "ee48d38b119b0cd71fe4141b30f5ba9c7c5d9f4e7a3a8b4a674e4b6ef789976f"
dependencies = [
"getrandom 0.3.4",
"js-sys",
@@ -10027,9 +9963,9 @@ checksum =
"ccf3ec651a847eb01de73ccad15eb7d99f80485de043efb2f370cd654f4ea44b"
[[package]]
name = "wasip2"
-version = "1.0.1+wasi-0.2.4"
+version = "1.0.2+wasi-0.2.9"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "0562428422c63773dad2c345a1882263bbf4d65cf3f42e90921f787ef5ad58e7"
+checksum = "9517f9239f02c069db75e65f174b3da828fe5f5b945c4dd26bd25d89c03ebcf5"
dependencies = [
"wit-bindgen",
]
@@ -10042,9 +9978,9 @@ checksum =
"b8dad83b4f25e74f184f64c43b150b91efe7647395b42289f38e50566d82855b"
[[package]]
name = "wasm-bindgen"
-version = "0.2.106"
+version = "0.2.108"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "0d759f433fa64a2d763d1340820e46e111a7a5ab75f993d1852d70b03dbb80fd"
+checksum = "64024a30ec1e37399cf85a7ffefebdb72205ca1c972291c51512360d90bd8566"
dependencies = [
"cfg-if",
"once_cell",
@@ -10055,11 +9991,12 @@ dependencies = [
[[package]]
name = "wasm-bindgen-futures"
-version = "0.4.56"
+version = "0.4.58"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "836d9622d604feee9e5de25ac10e3ea5f2d65b41eac0d9ce72eb5deae707ce7c"
+checksum = "70a6e77fd0ae8029c9ea0063f87c46fde723e7d887703d74ad2616d792e51e6f"
dependencies = [
"cfg-if",
+ "futures-util",
"js-sys",
"once_cell",
"wasm-bindgen",
@@ -10068,9 +10005,9 @@ dependencies = [
[[package]]
name = "wasm-bindgen-macro"
-version = "0.2.106"
+version = "0.2.108"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "48cb0d2638f8baedbc542ed444afc0644a29166f1595371af4fecf8ce1e7eeb3"
+checksum = "008b239d9c740232e71bd39e8ef6429d27097518b6b30bdf9086833bd5b6d608"
dependencies = [
"quote",
"wasm-bindgen-macro-support",
@@ -10078,9 +10015,9 @@ dependencies = [
[[package]]
name = "wasm-bindgen-macro-support"
-version = "0.2.106"
+version = "0.2.108"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "cefb59d5cd5f92d9dcf80e4683949f15ca4b511f4ac0a6e14d4e1ac60c6ecd40"
+checksum = "5256bae2d58f54820e6490f9839c49780dff84c65aeab9e772f15d5f0e913a55"
dependencies = [
"bumpalo",
"proc-macro2",
@@ -10091,9 +10028,9 @@ dependencies = [
[[package]]
name = "wasm-bindgen-shared"
-version = "0.2.106"
+version = "0.2.108"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "cbc538057e648b67f72a982e708d485b2efa771e1ac05fec311f9f63e5800db4"
+checksum = "1f01b580c9ac74c8d8f0c0e4afb04eeef2acf145458e52c03845ee9cd23e3d12"
dependencies = [
"unicode-ident",
]
@@ -10127,9 +10064,9 @@ dependencies = [
[[package]]
name = "web-sys"
-version = "0.3.83"
+version = "0.3.85"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "9b32828d774c412041098d182a8b38b16ea816958e07cf40eec2bc080ae137ac"
+checksum = "312e32e551d92129218ea9a2452120f4aabc03529ef03e4d0d82fb2780608598"
dependencies = [
"js-sys",
"wasm-bindgen",
@@ -10685,9 +10622,9 @@ dependencies = [
[[package]]
name = "wit-bindgen"
-version = "0.46.0"
+version = "0.51.0"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "f17a85883d4e6d00e8a97c586de764dabcc06133f7f1d55dce5cdc070ad7fe59"
+checksum = "d7249219f66ced02969388cf2bb044a09756a083d0fab1e566056b04d9fbcaa5"
[[package]]
name = "writeable"
@@ -10718,7 +10655,7 @@ dependencies = [
"oid-registry",
"ring",
"rusticata-macros",
- "thiserror 2.0.17",
+ "thiserror 2.0.18",
"time",
]
@@ -10762,7 +10699,7 @@ dependencies = [
"rustversion",
"serde",
"slab",
- "thiserror 2.0.17",
+ "thiserror 2.0.18",
"tokio",
"tokise",
"tracing",
@@ -10842,18 +10779,18 @@ dependencies = [
[[package]]
name = "zerocopy"
-version = "0.8.33"
+version = "0.8.34"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "668f5168d10b9ee831de31933dc111a459c97ec93225beb307aed970d1372dfd"
+checksum = "71ddd76bcebeed25db614f82bf31a9f4222d3fbba300e6fb6c00afa26cbd4d9d"
dependencies = [
"zerocopy-derive",
]
[[package]]
name = "zerocopy-derive"
-version = "0.8.33"
+version = "0.8.34"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "2c7962b26b0a8685668b671ee4b54d007a67d4eaf05fda79ac0ecf41e32270f1"
+checksum = "d8187381b52e32220d50b255276aa16a084ec0a9017a0ca2152a1f55c539758d"
dependencies = [
"proc-macro2",
"quote",
@@ -10936,14 +10873,15 @@ dependencies = [
[[package]]
name = "zip"
-version = "7.1.0"
+version = "7.2.0"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "9013f1222db8a6d680f13a7ccdc60a781199cd09c2fa4eff58e728bb181757fc"
+checksum = "c42e33efc22a0650c311c2ef19115ce232583abbe80850bc8b66509ebef02de0"
dependencies = [
"crc32fast",
"flate2",
"indexmap 2.13.0",
"memchr",
+ "typed-path",
"zopfli",
]
@@ -10955,9 +10893,9 @@ checksum =
"40990edd51aae2c2b6907af74ffb635029d5788228222c4bb811e9351c0caad3"
[[package]]
name = "zmij"
-version = "1.0.14"
+version = "1.0.17"
source = "registry+https://github.com/rust-lang/crates.io-index";
-checksum = "bd8f3f50b848df28f887acb68e41201b5aea6bc8a8dacc00fb40635ff9a72fea"
+checksum = "02aae0f83f69aafc94776e879363e9771d7ecbffe2c7fbb6c14c5e00dfe88439"
[[package]]
name = "zopfli"
diff --git a/Cargo.toml b/Cargo.toml
index c76235a11..d845a659a 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -58,9 +58,9 @@ aes-gcm = "0.10.3"
ahash = { version = "0.8.12", features = ["serde"] }
anyhow = "1.0.100"
argon2 = "0.5.3"
-arrow = "=55.2.0"
-arrow-array = "=55.2.0"
-arrow-json = "=55.2.0"
+arrow = "57.0.0"
+arrow-array = "57.0.0"
+arrow-json = "57.0.0"
async-broadcast = "0.7.2"
async-channel = "2.5.0"
async-dropper = { version = "0.3.1", features = ["tokio", "simple"] }
@@ -133,8 +133,8 @@ futures-util = "0.3.31"
human-repr = "1.1.0"
humantime = "2.3.0"
hwlocality = "1.0.0-alpha.11"
-iceberg = "=0.6.0"
-iceberg-catalog-rest = "=0.6.0"
+iceberg = "0.8.0"
+iceberg-catalog-rest = "0.8.0"
iggy = { path = "core/sdk", version = "0.8.1-edge.1" }
iggy_binary_protocol = { path = "core/binary_protocol", version =
"0.8.1-edge.1" }
iggy_common = { path = "core/common", version = "0.8.1-edge.1" }
@@ -168,7 +168,8 @@ opentelemetry_sdk = { version = "0.31.0", features = [
"experimental_logs_batch_log_processor_with_async_runtime",
"experimental_trace_batch_span_processor_with_async_runtime",
] }
-parquet = "=55.2.0"
+parquet = "57.0.0"
+
passterm = "=2.0.1"
postcard = { version = "1.1.3", features = ["alloc"] }
predicates = "3.1.3"
diff --git a/DEPENDENCIES.md b/DEPENDENCIES.md
index 5404013af..7d4f8133a 100644
--- a/DEPENDENCIES.md
+++ b/DEPENDENCIES.md
@@ -13,7 +13,6 @@ actix-utils: 3.0.1, "Apache-2.0 OR MIT",
actix-web: 4.12.1, "Apache-2.0 OR MIT",
actix-web-codegen: 4.3.0, "Apache-2.0 OR MIT",
adler2: 2.0.1, "0BSD OR Apache-2.0 OR MIT",
-adler32: 1.2.0, "Zlib",
aead: 0.5.2, "Apache-2.0 OR MIT",
aes: 0.8.4, "Apache-2.0 OR MIT",
aes-gcm: 0.10.3, "Apache-2.0 OR MIT",
@@ -30,23 +29,23 @@ anstyle-parse: 0.2.7, "Apache-2.0 OR MIT",
anstyle-query: 1.1.5, "Apache-2.0 OR MIT",
anstyle-wincon: 3.0.11, "Apache-2.0 OR MIT",
anyhow: 1.0.100, "Apache-2.0 OR MIT",
-apache-avro: 0.17.0, "Apache-2.0",
+apache-avro: 0.21.0, "Apache-2.0",
arc-swap: 1.8.0, "Apache-2.0 OR MIT",
argon2: 0.5.3, "Apache-2.0 OR MIT",
array-init: 2.1.0, "Apache-2.0 OR MIT",
arrayref: 0.3.9, "BSD-2-Clause",
arrayvec: 0.7.6, "Apache-2.0 OR MIT",
-arrow-arith: 55.2.0, "Apache-2.0",
-arrow-array: 55.2.0, "Apache-2.0",
-arrow-buffer: 55.2.0, "Apache-2.0",
-arrow-cast: 55.2.0, "Apache-2.0",
-arrow-data: 55.2.0, "Apache-2.0",
-arrow-ipc: 55.2.0, "Apache-2.0",
-arrow-json: 55.2.0, "Apache-2.0",
-arrow-ord: 55.2.0, "Apache-2.0",
-arrow-schema: 55.2.0, "Apache-2.0",
-arrow-select: 55.2.0, "Apache-2.0",
-arrow-string: 55.2.0, "Apache-2.0",
+arrow-arith: 57.2.0, "Apache-2.0",
+arrow-array: 57.2.0, "Apache-2.0",
+arrow-buffer: 57.2.0, "Apache-2.0",
+arrow-cast: 57.2.0, "Apache-2.0",
+arrow-data: 57.2.0, "Apache-2.0",
+arrow-ipc: 57.2.0, "Apache-2.0",
+arrow-json: 57.2.0, "Apache-2.0",
+arrow-ord: 57.2.0, "Apache-2.0",
+arrow-schema: 57.2.0, "Apache-2.0",
+arrow-select: 57.2.0, "Apache-2.0",
+arrow-string: 57.2.0, "Apache-2.0",
as-any: 0.3.2, "Apache-2.0 OR MIT",
asn1-rs: 0.7.1, "Apache-2.0 OR MIT",
asn1-rs-derive: 0.6.0, "Apache-2.0 OR MIT",
@@ -72,8 +71,8 @@ atomic-polyfill: 1.0.3, "Apache-2.0 OR MIT",
atomic-waker: 1.1.2, "Apache-2.0 OR MIT",
autocfg: 1.5.0, "Apache-2.0 OR MIT",
autotools: 0.2.7, "MIT",
-aws-lc-rs: 1.15.2, "(Apache-2.0 OR ISC) AND ISC",
-aws-lc-sys: 0.35.0, "(Apache-2.0 OR ISC) AND ISC AND OpenSSL",
+aws-lc-rs: 1.15.4, "(Apache-2.0 OR ISC) AND ISC",
+aws-lc-sys: 0.37.0, "(Apache-2.0 OR ISC) AND ISC AND OpenSSL",
axum: 0.8.8, "MIT",
axum-core: 0.5.6, "MIT",
axum-macros: 0.5.0, "MIT",
@@ -124,7 +123,7 @@ bzip2: 0.6.1, "Apache-2.0 OR MIT",
camino: 1.2.2, "Apache-2.0 OR MIT",
cargo-platform: 0.3.2, "Apache-2.0 OR MIT",
cargo_metadata: 0.23.1, "MIT",
-cc: 1.2.52, "Apache-2.0 OR MIT",
+cc: 1.2.54, "Apache-2.0 OR MIT",
cesu8: 1.1.0, "Apache-2.0 OR MIT",
cfg-if: 1.0.4, "Apache-2.0 OR MIT",
cfg_aliases: 0.2.1, "MIT",
@@ -171,7 +170,6 @@ convert_case: 0.10.0, "MIT",
cookie: 0.16.2, "Apache-2.0 OR MIT",
core-foundation: 0.10.1, "Apache-2.0 OR MIT",
core-foundation-sys: 0.8.7, "Apache-2.0 OR MIT",
-core2: 0.4.0, "Apache-2.0 OR MIT",
core_affinity: 0.8.3, "Apache-2.0 OR MIT",
cpufeatures: 0.2.17, "Apache-2.0 OR MIT",
crc: 3.4.0, "Apache-2.0 OR MIT",
@@ -211,7 +209,6 @@ darling_core: 0.23.0, "MIT",
darling_macro: 0.20.11, "MIT",
darling_macro: 0.21.3, "MIT",
darling_macro: 0.23.0, "MIT",
-dary_heap: 0.3.8, "Apache-2.0 OR MIT",
dashmap: 6.1.0, "MIT",
data-encoding: 2.10.0, "MIT",
dbus: 0.9.10, "Apache-2.0 OR MIT",
@@ -279,9 +276,9 @@ ff: 0.13.1, "Apache-2.0 OR MIT",
fiat-crypto: 0.2.9, "Apache-2.0 OR BSD-1-Clause OR MIT",
figlet-rs: 0.1.5, "Apache-2.0",
figment: 0.10.19, "Apache-2.0 OR MIT",
-file-operation: 0.8.11, "MIT",
-filetime: 0.2.26, "Apache-2.0 OR MIT",
-find-msvc-tools: 0.1.7, "Apache-2.0 OR MIT",
+file-operation: 0.8.17, "MIT",
+filetime: 0.2.27, "Apache-2.0 OR MIT",
+find-msvc-tools: 0.1.8, "Apache-2.0 OR MIT",
flatbuffers: 25.12.19, "Apache-2.0",
flate2: 1.1.8, "Apache-2.0 OR MIT",
float-cmp: 0.10.0, "MIT",
@@ -374,8 +371,8 @@ hyper-util: 0.1.19, "MIT",
hyperlocal: 0.9.1, "MIT",
iana-time-zone: 0.1.64, "Apache-2.0 OR MIT",
iana-time-zone-haiku: 0.1.2, "Apache-2.0 OR MIT",
-iceberg: 0.6.0, "Apache-2.0",
-iceberg-catalog-rest: 0.6.0, "Apache-2.0",
+iceberg: 0.8.0, "Apache-2.0",
+iceberg-catalog-rest: 0.8.0, "Apache-2.0",
icu_collections: 2.1.1, "Unicode-3.0",
icu_locale_core: 2.1.1, "Unicode-3.0",
icu_normalizer: 2.1.1, "Unicode-3.0",
@@ -428,11 +425,13 @@ itertools: 0.14.0, "Apache-2.0 OR MIT",
itoa: 1.0.17, "Apache-2.0 OR MIT",
jiff: 0.2.18, "MIT OR Unlicense",
jiff-static: 0.2.18, "MIT OR Unlicense",
+jiff-tzdb: 0.1.5, "MIT OR Unlicense",
+jiff-tzdb-platform: 0.1.3, "MIT OR Unlicense",
jni: 0.21.1, "Apache-2.0 OR MIT",
jni-sys: 0.3.0, "Apache-2.0 OR MIT",
jobserver: 0.1.34, "Apache-2.0 OR MIT",
journal: 0.1.0, "Apache-2.0",
-js-sys: 0.3.83, "Apache-2.0 OR MIT",
+js-sys: 0.3.85, "Apache-2.0 OR MIT",
jsonwebtoken: 10.2.0, "MIT",
jwalk: 0.8.1, "MIT",
keccak: 0.1.5, "Apache-2.0 OR MIT",
@@ -453,12 +452,10 @@ lexical-write-integer: 1.0.6, "Apache-2.0 OR MIT",
libbz2-rs-sys: 0.2.2, "bzip2-1.0.6",
libc: 0.2.180, "Apache-2.0 OR MIT",
libdbus-sys: 0.2.7, "Apache-2.0 OR MIT",
-libflate: 2.2.1, "MIT",
-libflate_lz77: 2.2.0, "MIT",
libgit2-sys: 0.18.3+1.9.2, "Apache-2.0 OR MIT",
liblzma: 0.4.5, "Apache-2.0 OR MIT",
-liblzma-sys: 0.4.4, "Apache-2.0 OR MIT",
-libm: 0.2.15, "MIT",
+liblzma-sys: 0.4.5, "Apache-2.0 OR MIT",
+libm: 0.2.16, "MIT",
libmimalloc-sys: 0.1.44, "MIT",
libredox: 0.1.12, "MIT",
libsqlite3-sys: 0.30.1, "MIT",
@@ -476,7 +473,7 @@ logos-codegen: 0.15.1, "Apache-2.0 OR MIT",
logos-derive: 0.15.1, "Apache-2.0 OR MIT",
loom: 0.7.2, "MIT",
lru-slab: 0.1.2, "Apache-2.0 OR MIT OR Zlib",
-lz4_flex: 0.11.5, "MIT",
+lz4_flex: 0.12.0, "MIT",
macro_rules_attribute: 0.1.3, "MIT",
macro_rules_attribute-proc_macro: 0.1.3, "MIT",
matchers: 0.2.0, "MIT",
@@ -495,7 +492,7 @@ miniz_oxide: 0.8.9, "Apache-2.0 OR MIT OR Zlib",
mio: 1.1.1, "MIT",
mockall: 0.14.0, "Apache-2.0 OR MIT",
mockall_derive: 0.14.0, "Apache-2.0 OR MIT",
-moka: 0.12.12, "(Apache-2.0 OR MIT) AND Apache-2.0",
+moka: 0.12.13, "(Apache-2.0 OR MIT) AND Apache-2.0",
murmur3: 0.5.2, "Apache-2.0 OR MIT",
never-say-never: 6.6.666, "Apache-2.0 OR MIT OR Zlib",
nix: 0.30.1, "MIT",
@@ -506,7 +503,7 @@ nonzero_ext: 0.3.0, "Apache-2.0",
nonzero_lit: 0.1.2, "Apache-2.0 OR CC0-1.0 OR MIT",
normalize-line-endings: 0.3.0, "Apache-2.0",
notify: 8.2.0, "CC0-1.0",
-notify-types: 2.0.0, "Apache-2.0 OR MIT",
+notify-types: 2.1.0, "Apache-2.0 OR MIT",
nougat: 0.2.4, "Apache-2.0 OR MIT OR Zlib",
nougat-proc_macros: 0.2.4, "Apache-2.0 OR MIT OR Zlib",
ntapi: 0.4.2, "Apache-2.0 OR MIT",
@@ -515,7 +512,7 @@ num: 0.4.3, "Apache-2.0 OR MIT",
num-bigint: 0.4.6, "Apache-2.0 OR MIT",
num-bigint-dig: 0.8.6, "Apache-2.0 OR MIT",
num-complex: 0.4.6, "Apache-2.0 OR MIT",
-num-conv: 0.1.0, "Apache-2.0 OR MIT",
+num-conv: 0.2.0, "Apache-2.0 OR MIT",
num-integer: 0.1.46, "Apache-2.0 OR MIT",
num-iter: 0.1.45, "Apache-2.0 OR MIT",
num-modular: 0.6.1, "Apache-2.0",
@@ -533,10 +530,10 @@ oid-registry: 0.8.1, "Apache-2.0 OR MIT",
once_cell: 1.21.3, "Apache-2.0 OR MIT",
once_cell_polyfill: 1.70.2, "Apache-2.0 OR MIT",
opaque-debug: 0.3.1, "Apache-2.0 OR MIT",
-opendal: 0.54.1, "Apache-2.0",
+opendal: 0.55.0, "Apache-2.0",
openssl: 0.10.75, "Apache-2.0",
openssl-macros: 0.1.1, "Apache-2.0 OR MIT",
-openssl-probe: 0.2.0, "Apache-2.0 OR MIT",
+openssl-probe: 0.2.1, "Apache-2.0 OR MIT",
openssl-src: 300.5.4+3.5.4, "Apache-2.0 OR MIT",
openssl-sys: 0.9.111, "MIT",
opentelemetry: 0.31.0, "Apache-2.0",
@@ -557,7 +554,7 @@ papaya: 0.2.3, "MIT",
parking: 2.2.1, "Apache-2.0 OR MIT",
parking_lot: 0.12.5, "Apache-2.0 OR MIT",
parking_lot_core: 0.9.12, "Apache-2.0 OR MIT",
-parquet: 55.2.0, "Apache-2.0",
+parquet: 57.2.0, "Apache-2.0",
parse-display: 0.9.1, "Apache-2.0 OR MIT",
parse-display-derive: 0.9.1, "Apache-2.0 OR MIT",
partitions: 0.1.0, "Apache-2.0",
@@ -603,7 +600,7 @@ proc-macro-crate: 1.3.1, "Apache-2.0 OR MIT",
proc-macro-crate: 3.4.0, "Apache-2.0 OR MIT",
proc-macro-error: 1.0.4, "Apache-2.0 OR MIT",
proc-macro-error-attr: 1.0.4, "Apache-2.0 OR MIT",
-proc-macro2: 1.0.105, "Apache-2.0 OR MIT",
+proc-macro2: 1.0.106, "Apache-2.0 OR MIT",
proc-macro2-diagnostics: 0.10.1, "Apache-2.0 OR MIT",
prometheus-client: 0.24.0, "Apache-2.0 OR MIT",
prometheus-client-derive-encode: 0.5.0, "Apache-2.0 OR MIT",
@@ -622,7 +619,7 @@ quick-xml: 0.38.4, "MIT",
quinn: 0.11.9, "Apache-2.0 OR MIT",
quinn-proto: 0.11.13, "Apache-2.0 OR MIT",
quinn-udp: 0.5.14, "Apache-2.0 OR MIT",
-quote: 1.0.43, "Apache-2.0 OR MIT",
+quote: 1.0.44, "Apache-2.0 OR MIT",
r-efi: 5.3.0, "Apache-2.0 OR LGPL-2.1-or-later OR MIT",
radium: 0.7.0, "MIT",
rand: 0.8.5, "Apache-2.0 OR MIT",
@@ -635,7 +632,7 @@ rand_xoshiro: 0.7.0, "Apache-2.0 OR MIT",
raw-cpuid: 11.6.0, "MIT",
rayon: 1.11.0, "Apache-2.0 OR MIT",
rayon-core: 1.13.0, "Apache-2.0 OR MIT",
-rcgen: 0.14.6, "Apache-2.0 OR MIT",
+rcgen: 0.14.7, "Apache-2.0 OR MIT",
redox_syscall: 0.5.18, "MIT",
redox_syscall: 0.7.0, "MIT",
redox_users: 0.5.2, "MIT",
@@ -657,12 +654,11 @@ ring: 0.17.14, "Apache-2.0 AND ISC",
ringbuffer: 0.16.0, "MIT",
rkyv: 0.7.46, "MIT",
rkyv_derive: 0.7.46, "MIT",
-rle-decode-fast: 1.0.3, "Apache-2.0 OR MIT",
rmcp: 0.13.0, "Apache-2.0",
rmcp-macros: 0.13.0, "Apache-2.0",
rmp: 0.8.15, "MIT",
rmp-serde: 1.3.1, "MIT",
-roaring: 0.10.12, "Apache-2.0 OR MIT",
+roaring: 0.11.3, "Apache-2.0 OR MIT",
route-recognizer: 0.3.1, "MIT",
rsa: 0.9.10, "Apache-2.0 OR MIT",
rust-embed: 8.11.0, "MIT",
@@ -677,10 +673,10 @@ rustix: 1.1.3, "Apache-2.0 OR Apache-2.0 WITH
LLVM-exception OR MIT",
rustls: 0.23.36, "Apache-2.0 OR ISC OR MIT",
rustls-native-certs: 0.8.3, "Apache-2.0 OR ISC OR MIT",
rustls-pemfile: 2.2.0, "Apache-2.0 OR ISC OR MIT",
-rustls-pki-types: 1.13.2, "Apache-2.0 OR MIT",
+rustls-pki-types: 1.14.0, "Apache-2.0 OR MIT",
rustls-platform-verifier: 0.6.2, "Apache-2.0 OR MIT",
rustls-platform-verifier-android: 0.1.1, "Apache-2.0 OR MIT",
-rustls-webpki: 0.103.8, "ISC",
+rustls-webpki: 0.103.9, "ISC",
rustversion: 1.0.22, "Apache-2.0 OR MIT",
ryu: 1.0.22, "Apache-2.0 OR BSL-1.0",
same-file: 1.0.6, "MIT OR Unlicense",
@@ -740,7 +736,7 @@ snafu: 0.8.9, "Apache-2.0 OR MIT",
snafu-derive: 0.8.9, "Apache-2.0 OR MIT",
snap: 1.1.1, "BSD-3-Clause",
socket2: 0.5.10, "Apache-2.0 OR MIT",
-socket2: 0.6.1, "Apache-2.0 OR MIT",
+socket2: 0.6.2, "Apache-2.0 OR MIT",
spin: 0.9.8, "MIT",
spinning_top: 0.3.0, "Apache-2.0 OR MIT",
spki: 0.7.3, "Apache-2.0 OR MIT",
@@ -758,9 +754,7 @@ stringprep: 0.1.5, "Apache-2.0 OR MIT",
strsim: 0.11.1, "MIT",
structmeta: 0.3.0, "Apache-2.0 OR MIT",
structmeta-derive: 0.3.0, "Apache-2.0 OR MIT",
-strum: 0.26.3, "MIT",
strum: 0.27.2, "MIT",
-strum_macros: 0.26.4, "MIT",
strum_macros: 0.27.2, "MIT",
subtle: 2.6.1, "BSD-3-Clause",
syn: 1.0.109, "Apache-2.0 OR MIT",
@@ -784,15 +778,14 @@ testcontainers: 0.26.3, "Apache-2.0 OR MIT",
testcontainers-modules: 0.14.0, "MIT",
textwrap: 0.16.2, "MIT",
thiserror: 1.0.69, "Apache-2.0 OR MIT",
-thiserror: 2.0.17, "Apache-2.0 OR MIT",
+thiserror: 2.0.18, "Apache-2.0 OR MIT",
thiserror-impl: 1.0.69, "Apache-2.0 OR MIT",
-thiserror-impl: 2.0.17, "Apache-2.0 OR MIT",
+thiserror-impl: 2.0.18, "Apache-2.0 OR MIT",
thread_local: 1.1.9, "Apache-2.0 OR MIT",
-threadpool: 1.8.1, "Apache-2.0 OR MIT",
thrift: 0.17.0, "Apache-2.0",
-time: 0.3.45, "Apache-2.0 OR MIT",
-time-core: 0.1.7, "Apache-2.0 OR MIT",
-time-macros: 0.2.25, "Apache-2.0 OR MIT",
+time: 0.3.46, "Apache-2.0 OR MIT",
+time-core: 0.1.8, "Apache-2.0 OR MIT",
+time-macros: 0.2.26, "Apache-2.0 OR MIT",
tiny-keccak: 2.0.2, "CC0-1.0",
tinystr: 0.8.2, "Unicode-3.0",
tinyvec: 1.10.0, "Apache-2.0 OR MIT OR Zlib",
@@ -832,12 +825,11 @@ trait-variant: 0.1.2, "Apache-2.0 OR MIT",
try-lock: 0.2.5, "MIT",
tungstenite: 0.28.0, "Apache-2.0 OR MIT",
twox-hash: 2.1.2, "MIT",
-typed-builder: 0.19.1, "Apache-2.0 OR MIT",
typed-builder: 0.20.1, "Apache-2.0 OR MIT",
typed-builder: 0.23.2, "Apache-2.0 OR MIT",
-typed-builder-macro: 0.19.1, "Apache-2.0 OR MIT",
typed-builder-macro: 0.20.1, "Apache-2.0 OR MIT",
typed-builder-macro: 0.23.2, "Apache-2.0 OR MIT",
+typed-path: 0.12.1, "Apache-2.0 OR MIT",
typenum: 1.19.0, "Apache-2.0 OR MIT",
ucd-trie: 0.1.7, "Apache-2.0 OR MIT",
ulid: 1.2.1, "MIT",
@@ -863,7 +855,7 @@ utf-8: 0.7.6, "Apache-2.0 OR MIT",
utf8-width: 0.1.8, "MIT",
utf8_iter: 1.0.4, "Apache-2.0 OR MIT",
utf8parse: 0.2.2, "Apache-2.0 OR MIT",
-uuid: 1.19.0, "Apache-2.0 OR MIT",
+uuid: 1.20.0, "Apache-2.0 OR MIT",
v_htmlescape: 0.15.8, "Apache-2.0 OR MIT",
valuable: 0.1.1, "MIT",
value-trait: 0.12.1, "Apache-2.0 OR MIT",
@@ -877,16 +869,16 @@ wait-timeout: 0.2.1, "Apache-2.0 OR MIT",
walkdir: 2.5.0, "MIT OR Unlicense",
want: 0.3.1, "MIT",
wasi: 0.11.1+wasi-snapshot-preview1, "Apache-2.0 OR Apache-2.0 WITH
LLVM-exception OR MIT",
-wasip2: 1.0.1+wasi-0.2.4, "Apache-2.0 OR Apache-2.0 WITH LLVM-exception OR
MIT",
+wasip2: 1.0.2+wasi-0.2.9, "Apache-2.0 OR Apache-2.0 WITH LLVM-exception OR
MIT",
wasite: 0.1.0, "Apache-2.0 OR BSL-1.0 OR MIT",
-wasm-bindgen: 0.2.106, "Apache-2.0 OR MIT",
-wasm-bindgen-futures: 0.4.56, "Apache-2.0 OR MIT",
-wasm-bindgen-macro: 0.2.106, "Apache-2.0 OR MIT",
-wasm-bindgen-macro-support: 0.2.106, "Apache-2.0 OR MIT",
-wasm-bindgen-shared: 0.2.106, "Apache-2.0 OR MIT",
+wasm-bindgen: 0.2.108, "Apache-2.0 OR MIT",
+wasm-bindgen-futures: 0.4.58, "Apache-2.0 OR MIT",
+wasm-bindgen-macro: 0.2.108, "Apache-2.0 OR MIT",
+wasm-bindgen-macro-support: 0.2.108, "Apache-2.0 OR MIT",
+wasm-bindgen-shared: 0.2.108, "Apache-2.0 OR MIT",
wasm-streams: 0.4.2, "Apache-2.0 OR MIT",
wasmtimer: 0.4.3, "MIT",
-web-sys: 0.3.83, "Apache-2.0 OR MIT",
+web-sys: 0.3.85, "Apache-2.0 OR MIT",
web-time: 1.1.0, "Apache-2.0 OR MIT",
webpki-root-certs: 1.0.5, "CDLA-Permissive-2.0",
webpki-roots: 0.26.11, "CDLA-Permissive-2.0",
@@ -954,7 +946,7 @@ windows_x86_64_msvc: 0.52.6, "Apache-2.0 OR MIT",
windows_x86_64_msvc: 0.53.1, "Apache-2.0 OR MIT",
winnow: 0.5.40, "MIT",
winnow: 0.7.14, "MIT",
-wit-bindgen: 0.46.0, "Apache-2.0 OR Apache-2.0 WITH LLVM-exception OR MIT",
+wit-bindgen: 0.51.0, "Apache-2.0 OR Apache-2.0 WITH LLVM-exception OR MIT",
writeable: 0.6.2, "Unicode-3.0",
wyz: 0.5.1, "MIT",
x509-parser: 0.18.0, "Apache-2.0 OR MIT",
@@ -967,8 +959,8 @@ yew-router: 0.19.0, "Apache-2.0 OR MIT",
yew-router-macro: 0.19.0, "Apache-2.0 OR MIT",
yoke: 0.8.1, "Unicode-3.0",
yoke-derive: 0.8.1, "Unicode-3.0",
-zerocopy: 0.8.33, "Apache-2.0 OR BSD-2-Clause OR MIT",
-zerocopy-derive: 0.8.33, "Apache-2.0 OR BSD-2-Clause OR MIT",
+zerocopy: 0.8.34, "Apache-2.0 OR BSD-2-Clause OR MIT",
+zerocopy-derive: 0.8.34, "Apache-2.0 OR BSD-2-Clause OR MIT",
zerofrom: 0.1.6, "Unicode-3.0",
zerofrom-derive: 0.1.6, "Unicode-3.0",
zeroize: 1.8.2, "Apache-2.0 OR MIT",
@@ -976,9 +968,9 @@ zeroize_derive: 1.4.3, "Apache-2.0 OR MIT",
zerotrie: 0.2.3, "Unicode-3.0",
zerovec: 0.11.5, "Unicode-3.0",
zerovec-derive: 0.11.2, "Unicode-3.0",
-zip: 7.1.0, "MIT",
+zip: 7.2.0, "MIT",
zlib-rs: 0.5.5, "Zlib",
-zmij: 1.0.14, "MIT",
+zmij: 1.0.17, "MIT",
zopfli: 0.8.3, "Apache-2.0",
zstd: 0.13.3, "MIT",
zstd-safe: 7.2.4, "Apache-2.0 OR MIT",
diff --git a/core/connectors/sinks/iceberg_sink/src/catalog.rs
b/core/connectors/sinks/iceberg_sink/src/catalog.rs
index 2b4ab280c..54c27efac 100644
--- a/core/connectors/sinks/iceberg_sink/src/catalog.rs
+++ b/core/connectors/sinks/iceberg_sink/src/catalog.rs
@@ -18,24 +18,41 @@
use super::{Error, IcebergSinkConfig, IcebergSinkTypes};
use crate::props::init_props;
-use iceberg::Catalog;
-use iceberg_catalog_rest::{RestCatalog, RestCatalogConfig};
+use iceberg::{Catalog, CatalogBuilder};
+use iceberg_catalog_rest::{
+ REST_CATALOG_PROP_URI, REST_CATALOG_PROP_WAREHOUSE, RestCatalogBuilder,
+};
+
use std::collections::HashMap;
pub async fn init_catalog(config: &IcebergSinkConfig) -> Result<Box<dyn
Catalog>, Error> {
let props = init_props(config)?;
match config.catalog_type {
- IcebergSinkTypes::REST => Ok(Box::new(get_rest_catalog(config,
props))),
+ IcebergSinkTypes::REST => get_rest_catalog(config, props).await,
}
}
#[inline(always)]
-fn get_rest_catalog(config: &IcebergSinkConfig, props: HashMap<String,
String>) -> RestCatalog {
- let catalog_config = RestCatalogConfig::builder()
- .uri(config.uri.clone())
- .props(props.clone())
- .warehouse(config.warehouse.clone())
- .build();
+async fn get_rest_catalog(
+ config: &IcebergSinkConfig,
+ props: HashMap<String, String>,
+) -> Result<Box<dyn Catalog>, Error> {
+ let mut new_props = HashMap::from([
+ (REST_CATALOG_PROP_URI.to_string(), config.uri.clone()),
+ (
+ REST_CATALOG_PROP_WAREHOUSE.to_string(),
+ config.warehouse.clone(),
+ ),
+ ]);
+ new_props.extend(props);
+
+ let catalog = RestCatalogBuilder::default()
+ .load("rest", new_props)
+ .await
+ .map_err(|err| {
+ let error = format!("Failed to initialize REST catalog: {}", err);
+ Error::InitError(error)
+ })?;
- RestCatalog::new(catalog_config)
+ Ok(Box::new(catalog))
}
diff --git a/core/connectors/sinks/iceberg_sink/src/router/mod.rs
b/core/connectors/sinks/iceberg_sink/src/router/mod.rs
index 671de8d4d..8e60beedf 100644
--- a/core/connectors/sinks/iceberg_sink/src/router/mod.rs
+++ b/core/connectors/sinks/iceberg_sink/src/router/mod.rs
@@ -22,11 +22,14 @@ use arrow_json::ReaderBuilder;
use async_trait::async_trait;
use iceberg::TableIdent;
use iceberg::arrow::schema_to_arrow_schema;
-use iceberg::spec::{Literal, PrimitiveLiteral, PrimitiveType, Struct,
StructType};
+use iceberg::spec::{
+ Literal, PartitionKey, PartitionSpec, PrimitiveLiteral, PrimitiveType,
Struct, StructType,
+};
use iceberg::table::Table;
use iceberg::transaction::{ApplyTransactionAction, Transaction};
use iceberg::writer::base_writer::data_file_writer::DataFileWriterBuilder;
use iceberg::writer::file_writer::ParquetWriterBuilder;
+use iceberg::writer::file_writer::rolling_writer::RollingFileWriterBuilder;
use iceberg::writer::{IcebergWriter, IcebergWriterBuilder};
use iceberg::{
Catalog,
@@ -121,21 +124,37 @@ async fn write_data(
let parquet_writer_builder = ParquetWriterBuilder::new(
WriterProperties::default(),
table.metadata().current_schema().clone(),
- table.file_io().clone(),
- location,
- file_name_gen,
);
- let data_file_writer_builder = DataFileWriterBuilder::new(
+ let rolling_file_writer_builder =
RollingFileWriterBuilder::new_with_default_file_size(
parquet_writer_builder,
- get_partition_type_value(table.metadata().default_partition_type())?,
- table.metadata().default_partition_spec_id(),
+ table.file_io().clone(),
+ location.clone(),
+ file_name_gen.clone(),
);
- let mut writer = data_file_writer_builder.build().await.map_err(|err| {
- error!("Error while constructing data file writer: {}", err);
- Error::InitError(err.to_string())
- })?;
+ let data_file_writer_builder =
DataFileWriterBuilder::new(rolling_file_writer_builder);
+
+ let partition_spec = PartitionSpec::builder(table.current_schema_ref());
+
+ let partition_type =
get_partition_type_value(table.metadata().default_partition_type())?;
+
+ let mut writer = data_file_writer_builder
+ .build(match partition_type {
+ None => None,
+ Some(p_type) => Some(PartitionKey::new(
+ partition_spec
+ .build()
+ .map_err(|err| Error::InitError(err.to_string()))?,
+ table.current_schema_ref(),
+ p_type,
+ )),
+ })
+ .await
+ .map_err(|err| {
+ error!("Error while constructing data file writer: {}", err);
+ Error::InitError(err.to_string())
+ })?;
let msgs: Vec<&simd_json::OwnedValue> = messages
.iter()
