Skip to content

Commit 6d9cb35

Browse files
committed
cargo fmt
1 parent eb76197 commit 6d9cb35

File tree

2 files changed

+9
-3
lines changed

2 files changed

+9
-3
lines changed

src/query/formats/src/output_format/parquet.rs

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,14 @@ impl OutputFormat for ParquetOutputFormat {
5454
}
5555
let mut buf = Vec::with_capacity(DEFAULT_BLOCK_BUFFER_SIZE);
5656
// Unloading data, enable encoding unconditionally in this case, since ...
57-
let _ = blocks_to_parquet(&self.schema, blocks, &mut buf, TableCompression::Zstd, true, None)?;
57+
let _ = blocks_to_parquet(
58+
&self.schema,
59+
blocks,
60+
&mut buf,
61+
TableCompression::Zstd,
62+
true,
63+
None,
64+
)?;
5865
Ok(buf)
5966
}
6067
}

src/query/storages/common/blocks/src/parquet_rs.rs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -50,8 +50,7 @@ pub fn blocks_to_parquet(
5050
.set_writer_version(WriterVersion::PARQUET_2_0)
5151
.set_dictionary_enabled(true)
5252
} else {
53-
builder
54-
.set_dictionary_enabled(false)
53+
builder.set_dictionary_enabled(false)
5554
};
5655

5756
let props = builder.build();

0 commit comments

Comments
 (0)