fix

Author: bobhan1

be/src/olap/rowset/segment_v2/segment_prefetcher.cpp

@@ -89,10 +89,10 @@ void SegmentPrefetcher::build_all_data_blocks() {
     const auto& pages = ordinal_index->_pages;       // pages[i] = page pointer of page i
     const int num_pages = ordinal_index->_num_pages;
 
-    size_t last_block_id = static_cast<size_t>(-1);
-    rowid_t current_block_first_rowid = 0;
+    last_block_id = static_cast<size_t>(-1);
+    current_block_first_rowid = 0;
 
-    for (int page_idx = 0; page_idx < num_pages; ++page_idx) {
+    for (page_idx = 0; page_idx < num_pages; ++page_idx) {
         const auto& page = pages[page_idx];
 
         if (_is_forward) {
@@ -108,7 +108,7 @@ void SegmentPrefetcher::build_all_data_blocks() {
                     _block_sequence.emplace_back(last_block_id, current_block_first_rowid);
                 }
                 last_block_id = block_id;
-                current_block_first_rowid = ordinals[page_idx];
+                current_block_first_rowid = static_cast<rowid_t>(ordinals[page_idx]);
             }
         } else {
             // Backward: use the last ordinal in each block as first_rowid
@@ -119,7 +119,7 @@ void SegmentPrefetcher::build_all_data_blocks() {
                 }
                 last_block_id = block_id;
             }
-            current_block_first_rowid = ordinals[page_idx];
+            current_block_first_rowid = static_cast<rowid_t>(ordinals[page_idx]);
         }
     }
 

be/src/olap/rowset/segment_v2/variant/sparse_column_extract_iterator.h

@@ -85,22 +85,6 @@ class BaseSparseColumnProcessor : public ColumnIterator {
         throw doris::Exception(ErrorCode::NOT_IMPLEMENTED_ERROR, "not implement");
     }
 
-    Status init_prefetcher(const SegmentPrefetchParams& params) override {
-        if (has_sparse_column_cache()) {
-            return Status::OK();
-        }
-        return _sparse_column_reader->init_prefetcher(params);
-    }
-
-    void collect_prefetchers(
-            std::map<PrefetcherInitMethod, std::vector<SegmentPrefetcher*>>& prefetchers,
-            PrefetcherInitMethod init_method) override {
-        if (has_sparse_column_cache()) {
-            return;
-        }
-        _sparse_column_reader->collect_prefetchers(prefetchers, init_method);
-    }
-
     // Template method pattern for batch processing
     template <typename ReadMethod>
     Status _process_batch(ReadMethod&& read_method, size_t nrows,

be/src/olap/rowset/segment_v2/variant/sparse_column_merge_iterator.cpp

@@ -44,23 +44,6 @@ Status SparseColumnMergeIterator::seek_to_ordinal(ordinal_t ord) {
     return Status::OK();
 }
 
-Status SparseColumnMergeIterator::init_prefetcher(const SegmentPrefetchParams& params) {
-    RETURN_IF_ERROR(_sparse_column_reader->init_prefetcher(params));
-    for (auto& entry : _src_subcolumns_for_sparse) {
-        RETURN_IF_ERROR(entry->data.iterator->init_prefetcher(params));
-    }
-    return Status::OK();
-}
-
-void SparseColumnMergeIterator::collect_prefetchers(
-        std::map<PrefetcherInitMethod, std::vector<SegmentPrefetcher*>>& prefetchers,
-        PrefetcherInitMethod init_method) {
-    _sparse_column_reader->collect_prefetchers(prefetchers, init_method);
-    for (auto& entry : _src_subcolumns_for_sparse) {
-        entry->data.iterator->collect_prefetchers(prefetchers, init_method);
-    }
-}
-
 Status SparseColumnMergeIterator::init(const ColumnIteratorOptions& opts) {
     RETURN_IF_ERROR(_sparse_column_cache->init(opts));
     for (auto& entry : _src_subcolumns_for_sparse) {

be/src/olap/rowset/segment_v2/variant/sparse_column_merge_iterator.h

@@ -92,11 +92,6 @@ class SparseColumnMergeIterator : public BaseSparseColumnProcessor {
 
     Status seek_to_ordinal(ordinal_t ord) override;
 
-    Status init_prefetcher(const SegmentPrefetchParams& params) override;
-    void collect_prefetchers(
-            std::map<PrefetcherInitMethod, std::vector<SegmentPrefetcher*>>& prefetchers,
-            PrefetcherInitMethod init_method) override;
-
 private:
     template <typename ReadFunction>
     Status _read_subcolumns(ReadFunction&& read_func) {