Skip to content

Commit de08fc8

Browse files
ZENOTMExxchan
authored andcommitted
feat(writer): support partition writer (#16)
Co-authored-by: ZENOTME <st810918843@gmail.com>
1 parent 41e727d commit de08fc8

File tree

12 files changed

+1089
-10
lines changed

12 files changed

+1089
-10
lines changed

Cargo.lock

Lines changed: 1 addition & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

Cargo.toml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -50,6 +50,7 @@ arrow-ord = { version = "54.1.0" }
5050
arrow-schema = { version = "54.1.0" }
5151
arrow-select = { version = "54.1.0" }
5252
arrow-string = { version = "54.1.0" }
53+
arrow-row = { version = "54.1.0" }
5354
async-stream = "0.3.5"
5455
async-trait = "0.1.86"
5556
async-std = "1.12"

crates/iceberg/Cargo.toml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -49,6 +49,7 @@ arrow-array = { workspace = true }
4949
arrow-buffer = { workspace = true }
5050
arrow-cast = { workspace = true }
5151
arrow-ord = { workspace = true }
52+
arrow-row = { workspace = true }
5253
arrow-schema = { workspace = true }
5354
arrow-select = { workspace = true }
5455
arrow-string = { workspace = true }

crates/iceberg/src/arrow/mod.rs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -31,3 +31,5 @@ pub(crate) mod record_batch_transformer;
3131
mod value;
3232
pub use reader::*;
3333
pub use value::*;
34+
mod record_batch_partition_spliter;
35+
pub(crate) use record_batch_partition_spliter::*;

0 commit comments

Comments
 (0)