Skip to content

Commit 820aa41

Browse files
committed
fix conflict
1 parent 6dc2b71 commit 820aa41

File tree

3 files changed

+10
-8
lines changed

3 files changed

+10
-8
lines changed

Cargo.toml

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -57,7 +57,6 @@ ordered-float = "4.0.0"
5757
parquet = "50"
5858
pretty_assertions = "1.4.0"
5959
port_scanner = "0.1.5"
60-
parquet = { version = ">=46", features = ["async"] }
6160
reqwest = { version = "^0.11", features = ["json"] }
6261
rust_decimal = "1.31.0"
6362
serde = { version = "^1.0", features = ["rc"] }

crates/iceberg/src/io.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -54,8 +54,8 @@ use crate::{error::Result, Error, ErrorKind};
5454
use futures::{AsyncRead, AsyncSeek, AsyncWrite};
5555
use once_cell::sync::Lazy;
5656
use opendal::{Operator, Scheme};
57-
use tokio::io::{AsyncRead as TokioAsyncRead, AsyncSeek as TokioAsyncSeek};
5857
use tokio::io::AsyncWrite as TokioAsyncWrite;
58+
use tokio::io::{AsyncRead as TokioAsyncRead, AsyncSeek as TokioAsyncSeek};
5959
use url::Url;
6060

6161
/// Following are arguments for [s3 file io](https://py.iceberg.apache.org/configuration/#s3).

crates/iceberg/src/scan.rs

Lines changed: 9 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -314,14 +314,15 @@ mod tests {
314314
ManifestEntry::builder()
315315
.status(ManifestStatus::Added)
316316
.data_file(
317-
DataFile::builder()
317+
DataFileBuilder::default()
318318
.content(DataContentType::Data)
319319
.file_path(format!("{}/1.parquet", &self.table_location))
320320
.file_format(DataFileFormat::Parquet)
321321
.file_size_in_bytes(100)
322322
.record_count(1)
323323
.partition(Struct::from_iter([Some(Literal::long(100))]))
324-
.build(),
324+
.build()
325+
.unwrap(),
325326
)
326327
.build(),
327328
ManifestEntry::builder()
@@ -330,14 +331,15 @@ mod tests {
330331
.sequence_number(parent_snapshot.sequence_number())
331332
.file_sequence_number(parent_snapshot.sequence_number())
332333
.data_file(
333-
DataFile::builder()
334+
DataFileBuilder::default()
334335
.content(DataContentType::Data)
335336
.file_path(format!("{}/2.parquet", &self.table_location))
336337
.file_format(DataFileFormat::Parquet)
337338
.file_size_in_bytes(100)
338339
.record_count(1)
339340
.partition(Struct::from_iter([Some(Literal::long(200))]))
340-
.build(),
341+
.build()
342+
.unwrap(),
341343
)
342344
.build(),
343345
ManifestEntry::builder()
@@ -346,14 +348,15 @@ mod tests {
346348
.sequence_number(parent_snapshot.sequence_number())
347349
.file_sequence_number(parent_snapshot.sequence_number())
348350
.data_file(
349-
DataFile::builder()
351+
DataFileBuilder::default()
350352
.content(DataContentType::Data)
351353
.file_path(format!("{}/3.parquet", &self.table_location))
352354
.file_format(DataFileFormat::Parquet)
353355
.file_size_in_bytes(100)
354356
.record_count(1)
355357
.partition(Struct::from_iter([Some(Literal::long(300))]))
356-
.build(),
358+
.build()
359+
.unwrap(),
357360
)
358361
.build(),
359362
],

0 commit comments

Comments
 (0)