From bd8f02b91d5321f3510bfef9c2f78c0fb4b2728a Mon Sep 17 00:00:00 2001 From: Jorge Leitao Date: Mon, 18 Oct 2021 21:34:57 +0200 Subject: [PATCH] Bumped rust-s3 in example (#536) --- examples/s3/Cargo.toml | 2 +- examples/s3/src/main.rs | 3 ++- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/examples/s3/Cargo.toml b/examples/s3/Cargo.toml index a238257f904..ed47cc23aea 100644 --- a/examples/s3/Cargo.toml +++ b/examples/s3/Cargo.toml @@ -5,6 +5,6 @@ edition = "2018" [dependencies] arrow2 = { path = "../../", default-features = false, features = ["io_parquet", "io_parquet_compression"] } -rust-s3 = { version = "0.27.0-rc4", features = ["tokio"] } +rust-s3 = { version = "0.27.0", features = ["tokio"] } futures = "0.3" tokio = { version = "1.0.0", features = ["macros", "rt-multi-thread"] } diff --git a/examples/s3/src/main.rs b/examples/s3/src/main.rs index db98240f408..4e1f1d70ad2 100644 --- a/examples/s3/src/main.rs +++ b/examples/s3/src/main.rs @@ -50,7 +50,8 @@ async fn main() -> Result<()> { // pages of the first row group and first column // This is IO bounded and SHOULD be done in a shared thread pool (e.g. Tokio) - let pages = get_page_stream(&metadata, 0, 0, &mut reader, vec![]).await?; + let column_metadata = &metadata.row_groups[0].columns()[0]; + let pages = get_page_stream(column_metadata, &mut reader, None, vec![]).await?; // decompress the pages. This is CPU bounded and SHOULD be done in a dedicated thread pool (e.g. Rayon) let pages = pages.map(|compressed_page| decompress(compressed_page?, &mut vec![]));