Skip to content
Merged
Show file tree
Hide file tree
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -165,6 +165,7 @@ datafusion = { version = "52", features = ["serde"] }
datafusion-tracing = { version = "52" }
datafusion-datasource = { version = "52" }
object_store = { version = "0.12", features = ["aws", "gcp", "azure"] }
parquet-ext = { version = "0.3.0", git = "https://github.com/edgeandnode/parquet-ext.git", rev = "66855214cd1969911e459e78242c36eb91be3951", features = ["zstd"] }

# Crates that should follow the version used by DataFusion and Arrow
prost = "0.14.1"
Expand Down
1 change: 1 addition & 0 deletions crates/core/worker-core/Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -25,3 +25,4 @@ thiserror.workspace = true
tokio.workspace = true
tracing.workspace = true
url.workspace = true
parquet-ext.workspace = true
3 changes: 2 additions & 1 deletion crates/core/worker-core/src/parquet_writer.rs
Original file line number Diff line number Diff line change
Expand Up @@ -12,15 +12,16 @@
},
},
parquet::{
arrow::AsyncArrowWriter,
errors::ParquetError,
file::{metadata::KeyValue, properties::WriterProperties as ParquetWriterProperties},

Check warning on line 16 in crates/core/worker-core/src/parquet_writer.rs

View workflow job for this annotation

GitHub Actions / Check rustfmt style

Diff in /home/runner/work/amp/amp/crates/core/worker-core/src/parquet_writer.rs
},
};
use parquet_ext::AsyncArrowWriter;

use metadata_db::{
MetadataDb,
files::{FileId, FooterBytes},
physical_table_revision::LocationId,

Check warning on line 24 in crates/core/worker-core/src/parquet_writer.rs

View workflow job for this annotation

GitHub Actions / Check rustfmt style

Diff in /home/runner/work/amp/amp/crates/core/worker-core/src/parquet_writer.rs
};
use object_store::{ObjectMeta, buffered::BufWriter};
use url::Url;
Expand Down
Loading