Skip to content

Commit b991068

Browse files
ZENOTMEchenzl25
authored andcommitted
feat(writer): support partition writer (#16)
Co-authored-by: ZENOTME <[email protected]>
1 parent cac54c2 commit b991068

File tree

12 files changed

+1090
-10
lines changed

12 files changed

+1090
-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: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,9 @@ arrow-ord = { version = "55" }
5050
arrow-schema = { version = "55" }
5151
arrow-select = { version = "55" }
5252
arrow-string = { version = "55" }
53+
arrow-row = { version = "55" }
5354
as-any = "0.3.2"
55+
async-stream = "0.3.5"
5456
async-std = "1.12"
5557
async-trait = "0.1.88"
5658
aws-config = "1.6.1"

crates/iceberg/Cargo.toml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -51,6 +51,7 @@ arrow-array = { workspace = true }
5151
arrow-buffer = { workspace = true }
5252
arrow-cast = { workspace = true }
5353
arrow-ord = { workspace = true }
54+
arrow-row = { workspace = true }
5455
arrow-schema = { workspace = true }
5556
arrow-select = { workspace = true }
5657
arrow-string = { workspace = true }

crates/iceberg/src/arrow/mod.rs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -34,3 +34,5 @@ mod value;
3434

3535
pub use reader::*;
3636
pub use value::*;
37+
mod record_batch_partition_spliter;
38+
pub(crate) use record_batch_partition_spliter::*;

0 commit comments

Comments
 (0)