Skip to content

Commit

Permalink
remove prints
Browse files Browse the repository at this point in the history
  • Loading branch information
jordanrfrazier committed Jul 12, 2023
1 parent c0337dc commit d969986
Showing 1 changed file with 0 additions and 6 deletions.
6 changes: 0 additions & 6 deletions crates/sparrow-runtime/src/read/parquet_stream.rs
Original file line number Diff line number Diff line change
Expand Up @@ -45,13 +45,9 @@ pub(super) async fn new_parquet_stream(
.await
.change_context(Error::OpenParquetFile)?;

println!("Parquet schema: {:?}", parquet_file.schema);
println!("Projected schema: {:?}", projected_schema);

let reader_columns = get_columns_to_read(parquet_file.schema.as_ref(), projected_schema)
.into_report()
.change_context(Error::DetermineColumns)?;
println!("Reader columns: {:?}", reader_columns);

let stream = parquet_file
.read_stream(None, Some(reader_columns))
Expand All @@ -71,8 +67,6 @@ pub(super) async fn new_parquet_stream(
// Recreate the RecordBatch, to adjust nullability of columns.
// The schemas should be identical / compatible, but may have different
// nullability.
println!("Schema: {:?}", projected_schema);
println!("Raw batch: {:?}", raw_batch);
let batch = RecordBatch::try_new(projected_schema.clone(), raw_batch.columns().to_vec())
.into_report()
.change_context(Error::ReadingBatch)
Expand Down

0 comments on commit d969986

Please sign in to comment.