Struct Row

pub struct Row {
    fields: Vec<(String, Field)>,
}

Row represents a nested Parquet record.

Fields

fields: Vec<(String, Field)>

Implementations

impl Row

pub fn new(fields: Vec<(String, Field)>) -> Row

Constructs a Row from the list of fields and returns it.

pub fn len(&self) -> usize

Get the number of fields in this row.

pub fn into_columns(self) -> Vec<(String, Field)>

Move columns data out of the row. Useful to avoid internal data cloning.

Example

use std::fs::File;
use parquet::record::Row;
use parquet::file::reader::{FileReader, SerializedFileReader};

let file = File::open("/path/to/file").unwrap();
let reader = SerializedFileReader::new(file).unwrap();
let row: Row = reader.get_row_iter(None).unwrap().next().unwrap().unwrap();
let columns = row.into_columns();
println!("row columns: {:?}", columns);

pub fn get_column_iter(&self) -> RowColumnIter<'_>

Get an iterator to go through all columns in the row.

Example

use std::fs::File;
use parquet::record::Row;
use parquet::file::reader::{FileReader, SerializedFileReader};

let file = File::open("/path/to/file").unwrap();
let reader = SerializedFileReader::new(file).unwrap();
let row: Row = reader.get_row_iter(None).unwrap().next().unwrap().unwrap();
for (idx, (name, field)) in row.get_column_iter().enumerate() {
    println!("column index: {}, column name: {}, column value: {}", idx, name, field);
}

pub fn to_json_value(&self) -> Value

Converts the row into a JSON object.

Trait Implementations

impl Clone for Row

fn clone(&self) -> Row

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Row

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Display for Row

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl PartialEq for Row

fn eq(&self, other: &Row) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl RowAccessor for Row

fn get_bool(&self, i: usize) -> Result<bool>

Try to get a boolean value at the given index.

fn get_byte(&self, i: usize) -> Result<i8>

Try to get a byte value at the given index.

fn get_short(&self, i: usize) -> Result<i16>

Try to get a short value at the given index.

fn get_int(&self, i: usize) -> Result<i32>

Try to get a int value at the given index.

fn get_long(&self, i: usize) -> Result<i64>

Try to get a long value at the given index.

fn get_ubyte(&self, i: usize) -> Result<u8>

Try to get a ubyte value at the given index.

fn get_ushort(&self, i: usize) -> Result<u16>

Try to get a ushort value at the given index.

fn get_uint(&self, i: usize) -> Result<u32>

Try to get a uint value at the given index.

fn get_ulong(&self, i: usize) -> Result<u64>

Try to get a ulong value at the given index.

fn get_float16(&self, i: usize) -> Result<f16>

Try to get a float16 value at the given index.

fn get_float(&self, i: usize) -> Result<f32>

Try to get a float value at the given index.

fn get_double(&self, i: usize) -> Result<f64>

Try to get a double value at the given index.

fn get_timestamp_millis(&self, i: usize) -> Result<i64>

Try to get a date value at the given index.

fn get_timestamp_micros(&self, i: usize) -> Result<i64>

Try to get a date value at the given index.

fn get_decimal(&self, i: usize) -> Result<&Decimal>

Try to get a decimal value at the given index.

fn get_string(&self, i: usize) -> Result<&String>

Try to get a string value at the given index.

fn get_bytes(&self, i: usize) -> Result<&ByteArray>

Try to get a bytes value at the given index.

fn get_group(&self, i: usize) -> Result<&Row>

Try to get a group value at the given index.

fn get_list(&self, i: usize) -> Result<&List>

Try to get a list value at the given index.

fn get_map(&self, i: usize) -> Result<&Map>

Try to get a map value at the given index.

impl RowFormatter for Row

fn fmt(&self, i: usize) -> &dyn Display

Get Display reference for a given field.

impl StructuralPartialEq for Row