Skip to content

Commit 9759f76

Browse files
committed
fix
1 parent 59fbfad commit 9759f76

File tree

3 files changed

+5
-6
lines changed

3 files changed

+5
-6
lines changed

src/paimon/format/orc/orc_format_defs.h

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,7 @@ static inline const char ORC_READ_ENABLE_METRICS[] = "orc.read.enable-metrics";
4949

5050
static constexpr uint64_t MIN_ROW_GROUP_COUNT_IN_ONE_NATURAL_READ = 1;
5151
static inline const char ENABLE_PREFETCH_READ_SIZE_THRESHOLD[] =
52-
"aliorc.read.enable-prefetch-read-size-threshold";
52+
"orc.read.enable-prefetch-read-size-threshold";
5353
// Prefetching will not be enabled if the total amount of data queried is below this threshold, as
5454
// prefetching for very small data sets is not beneficial.
5555
static constexpr uint64_t DEFAULT_ENABLE_PREFETCH_READ_SIZE_THRESHOLD = 10ull * 1024 * 1024;

src/paimon/format/orc/orc_reader_wrapper.h

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,7 @@
3636

3737
namespace paimon::orc {
3838

39-
// The FileReaderWrapper is a decorator class designed to support GetNextRowToRead.
39+
// The OrcReaderWrapper is a decorator class designed to support GetNextRowToRead.
4040
class OrcReaderWrapper {
4141
public:
4242
~OrcReaderWrapper() {
@@ -54,7 +54,7 @@ class OrcReaderWrapper {
5454
ReadRangeGenerator::Create(reader.get(), natural_read_size, options));
5555
auto reader_wrapper = std::unique_ptr<OrcReaderWrapper>(
5656
new OrcReaderWrapper(std::move(reader), std::move(range_generator), file_name,
57-
batch_size, std::move(arrow_pool), orc_pool));
57+
batch_size, arrow_pool, orc_pool));
5858
return reader_wrapper;
5959
}
6060

@@ -76,7 +76,7 @@ class OrcReaderWrapper {
7676
}
7777

7878
Status SetReadRanges(const std::vector<std::pair<uint64_t, uint64_t>>& read_ranges) {
79-
// this is just a hint, apache orc not support this.
79+
// Intentionally a no-op: SetReadRanges is a best-effort hint only.
8080
return Status::OK();
8181
}
8282

@@ -101,7 +101,7 @@ class OrcReaderWrapper {
101101
range_generator_(std::move(range_generator)),
102102
file_name_(file_name),
103103
batch_size_(batch_size),
104-
arrow_pool_(std::move(arrow_pool)),
104+
arrow_pool_(arrow_pool),
105105
orc_pool_(orc_pool) {}
106106

107107
std::unique_ptr<::orc::Reader> reader_;

src/paimon/format/orc/read_range_generator.cpp

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -142,7 +142,6 @@ double ReadRangeGenerator::BytesPerGroup(const std::vector<uint64_t>& column_ids
142142
if (reader_->getNumberOfRows() == 0) {
143143
return 1;
144144
}
145-
std::unordered_set<uint64_t> target_columns(column_ids.begin(), column_ids.end());
146145
uint64_t max_column_id = std::numeric_limits<uint64_t>::max();
147146
uint64_t max_length = 0;
148147
for (const auto& column_id : column_ids) {

0 commit comments

Comments
 (0)