Skip to content

Commit 0baa151

Browse files
committed
Parquet fuzz tests (#1053)
1 parent 3dca969 commit 0baa151

File tree

3 files changed

+279
-100
lines changed

3 files changed

+279
-100
lines changed

parquet/src/arrow/array_reader.rs

Lines changed: 19 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -60,7 +60,7 @@ use crate::arrow::converter::{
6060
Int96ArrayConverter, Int96Converter, IntervalDayTimeArrayConverter,
6161
IntervalDayTimeConverter, IntervalYearMonthArrayConverter,
6262
IntervalYearMonthConverter, LargeBinaryArrayConverter, LargeBinaryConverter,
63-
LargeUtf8ArrayConverter, LargeUtf8Converter,
63+
LargeUtf8ArrayConverter, LargeUtf8Converter, Utf8ArrayConverter, Utf8Converter,
6464
};
6565
use crate::arrow::record_reader::RecordReader;
6666
use crate::arrow::schema::parquet_to_arrow_field;
@@ -1690,12 +1690,24 @@ impl<'a> ArrayReaderBuilder {
16901690
arrow_type,
16911691
)?))
16921692
} else {
1693-
use crate::arrow::arrow_array_reader::{
1694-
ArrowArrayReader, StringArrayConverter,
1695-
};
1696-
let converter = StringArrayConverter::new();
1697-
Ok(Box::new(ArrowArrayReader::try_new(
1698-
*page_iterator,
1693+
// use crate::arrow::arrow_array_reader::{
1694+
// ArrowArrayReader, StringArrayConverter,
1695+
// };
1696+
// let converter = StringArrayConverter::new();
1697+
// Ok(Box::new(ArrowArrayReader::try_new(
1698+
// *page_iterator,
1699+
// column_desc,
1700+
// converter,
1701+
// arrow_type,
1702+
// )?))
1703+
1704+
// TODO: TEMPORARY
1705+
let converter = Utf8Converter::new(Utf8ArrayConverter {});
1706+
Ok(Box::new(ComplexObjectArrayReader::<
1707+
ByteArrayType,
1708+
Utf8Converter,
1709+
>::new(
1710+
page_iterator,
16991711
column_desc,
17001712
converter,
17011713
arrow_type,

0 commit comments

Comments
 (0)