Skip to content

Commit 37d9992

Browse files
committed
fix code
1 parent 1d225af commit 37d9992

File tree

4 files changed

+13
-11
lines changed

4 files changed

+13
-11
lines changed

python/python/lance/fragment.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -348,7 +348,7 @@ def create(
348348
mode=mode,
349349
data_storage_version=data_storage_version,
350350
storage_options=storage_options,
351-
file_writer_options=file_writer_options
351+
file_writer_options=file_writer_options,
352352
)
353353

354354
@property

rust/lance-encoding/src/encodings/physical/value.rs

+1-2
Original file line numberDiff line numberDiff line change
@@ -140,9 +140,8 @@ impl ValuePageDecoder {
140140
let bytes_u8: Vec<u8> = self.data[0].to_vec();
141141
let buffer_compressor = GeneralBufferCompressor::get_compressor(self.compression_config);
142142
let mut uncompressed_bytes: Vec<u8> = Vec::new();
143-
println!("before decompress {}", bytes_u8.len());
144143
buffer_compressor.decompress(&bytes_u8, &mut uncompressed_bytes)?;
145-
println!("after decompress {}", uncompressed_bytes.len());
144+
146145
let mut bytes_in_ranges: Vec<Bytes> =
147146
Vec::with_capacity(self.uncompressed_range_offsets.len());
148147
for range in &self.uncompressed_range_offsets {

rust/lance/src/dataset/updater.rs

+1-1
Original file line numberDiff line numberDiff line change
@@ -148,7 +148,7 @@ impl Updater {
148148
&schema,
149149
&self.fragment.dataset().base,
150150
data_storage_version,
151-
None
151+
None,
152152
)
153153
.await
154154
}

rust/lance/src/dataset/write.rs

+10-7
Original file line numberDiff line numberDiff line change
@@ -252,7 +252,13 @@ pub async fn do_write_fragments(
252252
.boxed()
253253
};
254254

255-
let writer_generator = WriterGenerator::new(object_store, base_dir, schema, storage_version, params.clone());
255+
let writer_generator = WriterGenerator::new(
256+
object_store,
257+
base_dir,
258+
schema,
259+
storage_version,
260+
params.clone(),
261+
);
256262
let mut writer: Option<Box<dyn GenericWriter>> = None;
257263
let mut num_rows_in_current_file = 0;
258264
let mut fragments = Vec::new();
@@ -536,11 +542,8 @@ pub async fn open_writer(
536542
.unwrap_or_default();
537543
file_write_options.format_version = Some(storage_version);
538544
let writer = object_store.create(&full_path).await?;
539-
let file_writer = v2::writer::FileWriter::try_new(
540-
writer,
541-
schema.clone(),
542-
file_write_options,
543-
)?;
545+
let file_writer =
546+
v2::writer::FileWriter::try_new(writer, schema.clone(), file_write_options)?;
544547
let writer_adapter = V2WriterAdapter {
545548
writer: file_writer,
546549
path: filename,
@@ -585,7 +588,7 @@ impl WriterGenerator {
585588
&self.schema,
586589
&self.base_dir,
587590
self.storage_version,
588-
Some(&self.params)
591+
Some(&self.params),
589592
)
590593
.await?;
591594

0 commit comments

Comments
 (0)