Skip to content

Commit 22aa4c3

Browse files
krinartkrinart
committed
Fix
1 parent 8f64075 commit 22aa4c3

3 files changed

Lines changed: 19 additions & 0 deletions

File tree

‎crates/iceberg/src/arrow/caching_delete_file_loader.rs‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -936,6 +936,7 @@ mod tests {
936936
project_field_ids: vec![2, 3],
937937
predicate: None,
938938
deletes: vec![pos_del, eq_del],
939+
limit: None,
939940
partition: None,
940941
partition_spec: None,
941942
name_mapping: None,

‎crates/iceberg/src/arrow/delete_filter.rs‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -480,6 +480,7 @@ pub(crate) mod tests {
480480
partition_spec_id: 0,
481481
equality_ids: None,
482482
}],
483+
limit: None,
483484
partition: None,
484485
partition_spec: None,
485486
name_mapping: None,

‎crates/iceberg/src/arrow/reader.rs‎

Lines changed: 17 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2436,6 +2436,7 @@ message schema {
24362436
project_field_ids: vec![1],
24372437
predicate: None,
24382438
deletes: vec![],
2439+
limit: None,
24392440
partition: None,
24402441
partition_spec: None,
24412442
name_mapping: None,
@@ -2453,6 +2454,7 @@ message schema {
24532454
project_field_ids: vec![1],
24542455
predicate: None,
24552456
deletes: vec![],
2457+
limit: None,
24562458
partition: None,
24572459
partition_spec: None,
24582460
name_mapping: None,
@@ -2581,6 +2583,7 @@ message schema {
25812583
project_field_ids: vec![1, 2], // Request both columns 'a' and 'b'
25822584
predicate: None,
25832585
deletes: vec![],
2586+
limit: None,
25842587
partition: None,
25852588
partition_spec: None,
25862589
name_mapping: None,
@@ -2753,6 +2756,7 @@ message schema {
27532756
partition_spec_id: 0,
27542757
equality_ids: None,
27552758
}],
2759+
limit: None,
27562760
partition: None,
27572761
partition_spec: None,
27582762
name_mapping: None,
@@ -2971,6 +2975,7 @@ message schema {
29712975
partition_spec_id: 0,
29722976
equality_ids: None,
29732977
}],
2978+
limit: None,
29742979
partition: None,
29752980
partition_spec: None,
29762981
name_mapping: None,
@@ -3182,6 +3187,7 @@ message schema {
31823187
partition_spec_id: 0,
31833188
equality_ids: None,
31843189
}],
3190+
limit: None,
31853191
partition: None,
31863192
partition_spec: None,
31873193
name_mapping: None,
@@ -3286,6 +3292,7 @@ message schema {
32863292
project_field_ids: vec![1, 2],
32873293
predicate: None,
32883294
deletes: vec![],
3295+
limit: None,
32893296
partition: None,
32903297
partition_spec: None,
32913298
name_mapping: None,
@@ -3384,6 +3391,7 @@ message schema {
33843391
project_field_ids: vec![1, 3],
33853392
predicate: None,
33863393
deletes: vec![],
3394+
limit: None,
33873395
partition: None,
33883396
partition_spec: None,
33893397
name_mapping: None,
@@ -3471,6 +3479,7 @@ message schema {
34713479
project_field_ids: vec![1, 2, 3],
34723480
predicate: None,
34733481
deletes: vec![],
3482+
limit: None,
34743483
partition: None,
34753484
partition_spec: None,
34763485
name_mapping: None,
@@ -3572,6 +3581,7 @@ message schema {
35723581
project_field_ids: vec![1, 2],
35733582
predicate: None,
35743583
deletes: vec![],
3584+
limit: None,
35753585
partition: None,
35763586
partition_spec: None,
35773587
name_mapping: None,
@@ -3702,6 +3712,7 @@ message schema {
37023712
project_field_ids: vec![1, 2],
37033713
predicate: None,
37043714
deletes: vec![],
3715+
limit: None,
37053716
partition: None,
37063717
partition_spec: None,
37073718
name_mapping: None,
@@ -3799,6 +3810,7 @@ message schema {
37993810
project_field_ids: vec![1, 5, 2],
38003811
predicate: None,
38013812
deletes: vec![],
3813+
limit: None,
38023814
partition: None,
38033815
partition_spec: None,
38043816
name_mapping: None,
@@ -3909,6 +3921,7 @@ message schema {
39093921
project_field_ids: vec![1, 2, 3],
39103922
predicate: Some(predicate.bind(schema, true).unwrap()),
39113923
deletes: vec![],
3924+
limit: None,
39123925
partition: None,
39133926
partition_spec: None,
39143927
name_mapping: None,
@@ -4000,6 +4013,7 @@ message schema {
40004013
project_field_ids: vec![1, 2],
40014014
predicate: None,
40024015
deletes: vec![],
4016+
limit: None,
40034017
partition: None,
40044018
partition_spec: None,
40054019
name_mapping: None,
@@ -4015,6 +4029,7 @@ message schema {
40154029
project_field_ids: vec![1, 2],
40164030
predicate: None,
40174031
deletes: vec![],
4032+
limit: None,
40184033
partition: None,
40194034
partition_spec: None,
40204035
name_mapping: None,
@@ -4030,6 +4045,7 @@ message schema {
40304045
project_field_ids: vec![1, 2],
40314046
predicate: None,
40324047
deletes: vec![],
4048+
limit: None,
40334049
partition: None,
40344050
partition_spec: None,
40354051
name_mapping: None,
@@ -4209,6 +4225,7 @@ message schema {
42094225
project_field_ids: vec![1, 2],
42104226
predicate: None,
42114227
deletes: vec![],
4228+
limit: None,
42124229
partition: Some(partition_data),
42134230
partition_spec: Some(partition_spec),
42144231
name_mapping: None,

0 commit comments

Comments
 (0)