| 54 | } |
| 55 | |
| 56 | int64_t ScanAllValues(int32_t batch_size, int16_t* def_levels, int16_t* rep_levels, |
| 57 | uint8_t* values, int64_t* values_buffered, |
| 58 | parquet::ColumnReader* reader) { |
| 59 | switch (reader->type()) { |
| 60 | case parquet::Type::BOOLEAN: |
| 61 | return ScanAll<parquet::BoolReader>(batch_size, def_levels, rep_levels, values, |
| 62 | values_buffered, reader); |
| 63 | case parquet::Type::INT32: |
| 64 | return ScanAll<parquet::Int32Reader>(batch_size, def_levels, rep_levels, values, |
| 65 | values_buffered, reader); |
| 66 | case parquet::Type::INT64: |
| 67 | return ScanAll<parquet::Int64Reader>(batch_size, def_levels, rep_levels, values, |
| 68 | values_buffered, reader); |
| 69 | case parquet::Type::INT96: |
| 70 | return ScanAll<parquet::Int96Reader>(batch_size, def_levels, rep_levels, values, |
| 71 | values_buffered, reader); |
| 72 | case parquet::Type::FLOAT: |
| 73 | return ScanAll<parquet::FloatReader>(batch_size, def_levels, rep_levels, values, |
| 74 | values_buffered, reader); |
| 75 | case parquet::Type::DOUBLE: |
| 76 | return ScanAll<parquet::DoubleReader>(batch_size, def_levels, rep_levels, values, |
| 77 | values_buffered, reader); |
| 78 | case parquet::Type::BYTE_ARRAY: |
| 79 | return ScanAll<parquet::ByteArrayReader>(batch_size, def_levels, rep_levels, values, |
| 80 | values_buffered, reader); |
| 81 | case parquet::Type::FIXED_LEN_BYTE_ARRAY: |
| 82 | return ScanAll<parquet::FixedLenByteArrayReader>(batch_size, def_levels, rep_levels, |
| 83 | values, values_buffered, reader); |
| 84 | default: |
| 85 | parquet::ParquetException::NYI("type reader not implemented"); |
| 86 | } |
| 87 | // Unreachable code, but suppress compiler warning |
| 88 | return 0; |
| 89 | } |
| 90 | |
| 91 | } // namespace parquet |
no test coverage detected