Skip to content

Commit 7c77442

Browse files
Adapt parquet
1 parent b1aaf7b commit 7c77442

2 files changed

Lines changed: 5 additions & 2 deletions

File tree

‎include/rfl/parquet/read.hpp‎

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,8 @@ Result<internal::wrap_in_rfl_array_t<T>> read(
4242
return error("Could not read table: " + status.message());
4343
}
4444

45-
using ArrowReader = parsing::tabular::ArrowReader<T, Ps...>;
45+
using ArrowReader = parsing::tabular::ArrowReader<
46+
T, parsing::tabular::SerializationType::parquet, Ps...>;
4647

4748
return ArrowReader::make(table).and_then(
4849
[](const auto& _r) { return _r.read(); });

‎include/rfl/parquet/write.hpp‎

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,9 @@ Ref<arrow::Buffer> to_buffer(const auto& _arr, const Settings& _settings) {
2525
using T = std::remove_cvref_t<decltype(_arr)>;
2626

2727
const auto table =
28-
parsing::tabular::ArrowWriter<T, Ps...>(_settings.chunksize)
28+
parsing::tabular::ArrowWriter<
29+
T, parsing::tabular::SerializationType::parquet, Ps...>(
30+
_settings.chunksize)
2931
.to_table(_arr);
3032

3133
const auto props = ::parquet::WriterProperties::Builder()

0 commit comments

Comments
 (0)