Changed to released parquet2

jorgecarleitao · Feb 2, 2022 · 1c1dd10 · 1c1dd10
1 parent b3f9f10
commit 1c1dd10
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 2 deletions.
diff --git a/Cargo.toml b/Cargo.toml
@@ -68,8 +68,7 @@ futures = { version = "0.3", optional = true }
 ahash = { version = "0.7", optional = true }
 
 # parquet support
-#parquet2 = { version = "0.9", optional = true, default_features = false, features = ["stream"] }
-parquet2 = { git = "https://github.com/jorgecarleitao/parquet2", branch = "writer", optional = true, default_features = false, features = ["stream"] }
+parquet2 = { version = "0.10", optional = true, default_features = false, features = ["stream"] }
 
 # avro support
 avro-schema = { version = "0.2", optional = true }

diff --git a/tests/it/io/parquet/mod.rs b/tests/it/io/parquet/mod.rs
@@ -645,6 +645,7 @@ fn integration_write(schema: &Schema, batches: &[Chunk<Arc<dyn Array>>]) -> Resu
 
  let mut writer = FileWriter::try_new(writer, schema.clone(), options)?;
 
+ writer.start()?;
  for group in row_groups {
  let (group, len) = group?;
  writer.write(group, len)?;

diff --git a/tests/it/io/parquet/write.rs b/tests/it/io/parquet/write.rs
@@ -47,6 +47,7 @@ fn round_trip(
  let writer = Cursor::new(vec![]);
  let mut writer = FileWriter::try_new(writer, schema, options)?;
 
+ writer.start()?;
  for group in row_groups {
  let (group, len) = group?;
  writer.write(group, len)?;