Skip to content

Commit 7f0466e

Browse files
committed
fix
1 parent a5f7c34 commit 7f0466e

2 files changed

Lines changed: 4 additions & 6 deletions

File tree

src/paimon/format/parquet/file_reader_wrapper.cpp

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -399,13 +399,11 @@ Status FileReaderWrapper::PrepareForReadingLazy(
399399

400400
std::vector<::arrow::io::ReadRange> FileReaderWrapper::CollectPreBufferRanges(
401401
const std::vector<int32_t>& column_indices, uint64_t start_idx) {
402-
return DoCollectPreBufferRanges(column_indices, /*skip_read_range_excluded=*/true,
403-
start_idx);
402+
return DoCollectPreBufferRanges(column_indices, /*skip_read_range_excluded=*/true, start_idx);
404403
}
405404

406405
std::vector<::arrow::io::ReadRange> FileReaderWrapper::DoCollectPreBufferRanges(
407-
const std::vector<int32_t>& column_indices, bool skip_read_range_excluded,
408-
uint64_t start_idx) {
406+
const std::vector<int32_t>& column_indices, bool skip_read_range_excluded, uint64_t start_idx) {
409407
std::vector<::arrow::io::ReadRange> ranges;
410408
auto file_metadata = file_reader_->parquet_reader()->metadata();
411409

src/paimon/format/parquet/file_reader_wrapper_test.cpp

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -188,8 +188,8 @@ class FileReaderWrapperTest : public ::testing::Test {
188188
Result<std::unique_ptr<FileReaderWrapper>> PrepareReaderWrapperOnStream(
189189
std::shared_ptr<InputStream> in, int64_t wrapper_batch_size = 0) {
190190
PAIMON_ASSIGN_OR_RAISE(int64_t file_length, in->Length());
191-
auto input_stream = std::make_unique<ArrowInputStreamAdapter>(std::move(in), file_length,
192-
arrow_pool_);
191+
auto input_stream =
192+
std::make_unique<ArrowInputStreamAdapter>(std::move(in), file_length, arrow_pool_);
193193
::parquet::arrow::FileReaderBuilder file_reader_builder;
194194
::parquet::ReaderProperties reader_properties;
195195
reader_properties.enable_buffered_stream();

0 commit comments

Comments
 (0)