Skip to content

Commit ff1b68c

Browse files
committed
fix(parquet): include metadata definitions in cached stream
1 parent e1378bd commit ff1b68c

2 files changed

Lines changed: 3 additions & 2 deletions

File tree

‎src/paimon/format/parquet/parquet_input_stream.h‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,7 @@
2929
#include "paimon/common/utils/arrow/arrow_input_stream_adapter.h"
3030
#include "paimon/common/utils/arrow/status_utils.h"
3131
#include "paimon/memory/memory_pool.h"
32+
#include "parquet/metadata.h"
3233
#include "parquet/page_index.h"
3334

3435
namespace paimon::parquet {

‎src/paimon/format/parquet/parquet_reader_builder.h‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -89,8 +89,8 @@ class ParquetReaderBuilder : public ReaderBuilder {
8989
file_uri = std::move(file_uri_result).value();
9090
}
9191
}
92-
auto input_stream = std::make_shared<ParquetInputStream>(
93-
path, file_length, arrow_pool_, pool_, cache_, file_uri);
92+
auto input_stream = std::make_shared<ParquetInputStream>(path, file_length, arrow_pool_,
93+
pool_, cache_, file_uri);
9494
auto storage_read_bytes = input_stream->StorageReadBytes();
9595
PAIMON_ASSIGN_OR_RAISE(std::shared_ptr<::parquet::FileMetaData> file_metadata,
9696
GetCachedParquetMetadata(input_stream, file_uri, arrow_pool_));

0 commit comments

Comments
 (0)