Skip to content

Commit dacc38d

Browse files
committed
fix review again
1 parent 607bc4e commit dacc38d

File tree

4 files changed

+6
-15
lines changed

4 files changed

+6
-15
lines changed

src/iceberg/arrow_array_reader.h

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,7 @@
2727

2828
namespace iceberg {
2929

30+
/// \brief A reader interface that returns ArrowArray in a streaming fashion.
3031
class ICEBERG_EXPORT ArrowArrayReader {
3132
public:
3233
/// \brief Read next batch of data.

src/iceberg/table_scan.cc

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -19,10 +19,6 @@
1919

2020
#include "iceberg/table_scan.h"
2121

22-
#include <algorithm>
23-
#include <ranges>
24-
#include <utility>
25-
2622
#include "iceberg/file_reader.h"
2723
#include "iceberg/manifest_entry.h"
2824
#include "iceberg/manifest_list.h"
@@ -59,7 +55,7 @@ Result<std::unique_ptr<ArrowArrayReader>> FileScanTask::ToArrowArrayReader(
5955
ICEBERG_ASSIGN_OR_RAISE(auto reader,
6056
ReaderFactoryRegistry::Open(data_file_->file_format, options));
6157

62-
return std::move(reader);
58+
return reader;
6359
}
6460

6561
TableScanBuilder::TableScanBuilder(std::shared_ptr<TableMetadata> table_metadata,

src/iceberg/table_scan.h

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -51,21 +51,15 @@ class ICEBERG_EXPORT FileScanTask : public ScanTask {
5151
/// \brief The data file that should be read by this scan task.
5252
const std::shared_ptr<DataFile>& data_file() const;
5353

54-
/// \brief The total size in bytes of the file split to be read.
5554
int64_t size_bytes() const override;
5655

57-
/// \brief The number of files that should be read by this scan task.
5856
int32_t files_count() const override;
5957

60-
/// \brief The number of rows that should be read by this scan task.
6158
int64_t estimated_row_count() const override;
6259

6360
/**
6461
* \brief Returns an ArrowArrayReader to read the data for this task.
6562
*
66-
* This acts as a factory to instantiate a file-format-specific reader (e.g., Parquet)
67-
* based on the metadata in this task and the provided parameters.
68-
*
6963
* \param projected_schema The projected schema for reading the data.
7064
* \param filter Optional filter expression to apply during reading.
7165
* \param io The FileIO instance for accessing the file data.

test/file_scan_task_test.cc

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -120,9 +120,9 @@ TEST_F(FileScanTaskTest, ReadFullSchema) {
120120
data_file->file_path = temp_parquet_file_;
121121
data_file->file_format = FileFormatType::kParquet;
122122

123-
auto io_internal = internal::checked_cast<arrow::ArrowFileSystemFileIO&>(*file_io_);
123+
auto io = internal::checked_cast<arrow::ArrowFileSystemFileIO&>(*file_io_);
124124
data_file->file_size_in_bytes =
125-
io_internal.fs()->GetFileInfo(temp_parquet_file_).ValueOrDie().size();
125+
io.fs()->GetFileInfo(temp_parquet_file_).ValueOrDie().size();
126126

127127
auto projected_schema = std::make_shared<Schema>(
128128
std::vector<SchemaField>{SchemaField::MakeRequired(1, "id", int32()),
@@ -144,9 +144,9 @@ TEST_F(FileScanTaskTest, ReadProjectedAndReorderedSchema) {
144144
data_file->file_path = temp_parquet_file_;
145145
data_file->file_format = FileFormatType::kParquet;
146146

147-
auto io_internal = internal::checked_cast<arrow::ArrowFileSystemFileIO&>(*file_io_);
147+
auto io = internal::checked_cast<arrow::ArrowFileSystemFileIO&>(*file_io_);
148148
data_file->file_size_in_bytes =
149-
io_internal.fs()->GetFileInfo(temp_parquet_file_).ValueOrDie().size();
149+
io.fs()->GetFileInfo(temp_parquet_file_).ValueOrDie().size();
150150

151151
auto projected_schema = std::make_shared<Schema>(
152152
std::vector<SchemaField>{SchemaField::MakeOptional(2, "name", string()),

0 commit comments

Comments
 (0)