Updated examples.

examples/parquet_read.rs

@@ -21,13 +21,13 @@ fn read_field(path: &str, row_group: usize, field: usize) -> Result<Box<dyn Arra
     // yields an iterator of compressed pages. There is almost no CPU work in iterating.
     let columns = read::get_column_iterator(&mut file, &metadata, row_group, field, None, vec![]);
 
-    // get the columns' logical type
-    let data_type = arrow_schema.fields()[field].data_type().clone();
+    // get the columns' field
+    let field = &arrow_schema.fields()[field];
 
     // This is the actual work. In this case, pages are read and
     // decompressed, decoded and deserialized to arrow.
     // Because `columns` is an iterator, it uses a combination of IO and CPU.
-    let (array, _, _) = read::column_iter_to_array(columns, data_type, vec![])?;
+    let (array, _, _) = read::column_iter_to_array(columns, field, vec![])?;
 
     Ok(array)
 }

examples/parquet_read_parallel.rs

@@ -64,14 +64,14 @@ fn parallel_read(path: &str, row_group: usize) -> Result<RecordBatch> {
             let arrow_schema_consumer = arrow_schema.clone();
             thread::spawn(move || {
                 let mut arrays = vec![];
-                while let Ok((field_i, field, column_chunks)) = rx_consumer.recv() {
+                while let Ok((field_i, parquet_field, column_chunks)) = rx_consumer.recv() {
                     let start = SystemTime::now();
-                    let data_type = arrow_schema_consumer.fields()[field_i].data_type().clone();
+                    let field = &arrow_schema_consumer.fields()[field_i];
                     println!("consumer {} start - {}", i, field_i);
 
-                    let columns = read::ReadColumnIterator::new(field, column_chunks);
+                    let columns = read::ReadColumnIterator::new(parquet_field, column_chunks);
 
-                    let array = read::column_iter_to_array(columns, data_type, vec![]).map(|x| x.0);
+                    let array = read::column_iter_to_array(columns, field, vec![]).map(|x| x.0);
                     println!(
                         "consumer {} end - {:?}: {}",
                         i,