/root/doris/be/src/olap/base_compaction.h
| Line | Count | Source (jump to first uncovered line) | 
| 1 |  | // Licensed to the Apache Software Foundation (ASF) under one | 
| 2 |  | // or more contributor license agreements.  See the NOTICE file | 
| 3 |  | // distributed with this work for additional information | 
| 4 |  | // regarding copyright ownership.  The ASF licenses this file | 
| 5 |  | // to you under the Apache License, Version 2.0 (the | 
| 6 |  | // "License"); you may not use this file except in compliance | 
| 7 |  | // with the License.  You may obtain a copy of the License at | 
| 8 |  | // | 
| 9 |  | //   http://www.apache.org/licenses/LICENSE-2.0 | 
| 10 |  | // | 
| 11 |  | // Unless required by applicable law or agreed to in writing, | 
| 12 |  | // software distributed under the License is distributed on an | 
| 13 |  | // "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY | 
| 14 |  | // KIND, either express or implied.  See the License for the | 
| 15 |  | // specific language governing permissions and limitations | 
| 16 |  | // under the License. | 
| 17 |  |  | 
| 18 |  | #pragma once | 
| 19 |  |  | 
| 20 |  | #include <string> | 
| 21 |  | #include <vector> | 
| 22 |  |  | 
| 23 |  | #include "common/status.h" | 
| 24 |  | #include "io/io_common.h" | 
| 25 |  | #include "olap/compaction.h" | 
| 26 |  |  | 
| 27 |  | namespace doris { | 
| 28 |  |  | 
| 29 |  | // BaseCompaction is derived from Compaction. | 
| 30 |  | // BaseCompaction will implements | 
| 31 |  | //   1. its policy to pick rowsets | 
| 32 |  | //   2. do compaction to produce new rowset. | 
| 33 |  |  | 
| 34 |  | class BaseCompaction final : public CompactionMixin { | 
| 35 |  | public: | 
| 36 |  |     BaseCompaction(StorageEngine& engine, const TabletSharedPtr& tablet); | 
| 37 |  |     ~BaseCompaction() override; | 
| 38 |  |  | 
| 39 |  |     Status prepare_compact() override; | 
| 40 |  |  | 
| 41 |  |     Status execute_compact() override; | 
| 42 |  |  | 
| 43 |  | private: | 
| 44 |  |     Status pick_rowsets_to_compact(); | 
| 45 | 0 |     std::string_view compaction_name() const override { return "base compaction"; } | 
| 46 |  |  | 
| 47 | 68 |     ReaderType compaction_type() const override { return ReaderType::READER_BASE_COMPACTION; } | 
| 48 |  |  | 
| 49 |  |     // filter input rowset in some case: | 
| 50 |  |     // 1. dup key without delete predicate | 
| 51 |  |     void _filter_input_rowset(); | 
| 52 |  | }; | 
| 53 |  |  | 
| 54 |  | } // namespace doris |