Skip to content

Commit 0dc5ffd

Browse files
authored
Remove code (#2721)
### What problem does this PR solve? Remove unused code ### Type of change - [x] Refactoring --------- Signed-off-by: Jin Hai <[email protected]>
1 parent 477428f commit 0dc5ffd

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

41 files changed

+50
-769
lines changed

src/common/third_party.cppm

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -71,15 +71,15 @@ module;
7171
#include <miniocpp/client.h>
7272

7373
#include "rocksdb/db.h"
74+
#include "rocksdb/env.h"
75+
#include "rocksdb/io_status.h"
76+
#include "rocksdb/merge_operator.h"
7477
#include "rocksdb/options.h"
7578
#include "rocksdb/slice.h"
76-
#include "rocksdb/io_status.h"
77-
#include "rocksdb/utilities/transaction.h"
78-
#include "rocksdb/utilities/transaction_db.h"
7979
#include "rocksdb/utilities/backup_engine.h"
8080
#include "rocksdb/utilities/merge_operators.h"
81-
#include "rocksdb/merge_operator.h"
82-
#include "rocksdb/env.h"
81+
#include "rocksdb/utilities/transaction.h"
82+
#include "rocksdb/utilities/transaction_db.h"
8383

8484
#pragma clang diagnostic pop
8585

src/executor/operator/physical_scan/physical_match_sparse_scan.cpp

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,6 @@ import internal_types;
4747
import knn_result_handler;
4848
import merge_knn;
4949
import match_sparse_scan_function_data;
50-
import fix_heap;
5150
import global_block_id;
5251
import roaring_bitmap;
5352
import bmp_index_file_worker;

src/executor/operator/physical_scan/physical_match_tensor_scan.cpp

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -56,7 +56,6 @@ import global_block_id;
5656
import block_index;
5757
import column_def;
5858
import internal_types;
59-
import fix_heap;
6059
import type_info;
6160
import embedding_info;
6261
import buffer_manager;

src/function/cast/sparse_cast.cppm

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@ import internal_types;
2828
import column_vector;
2929
import third_party;
3030
import vector_buffer;
31-
import fix_heap;
31+
3232
import sparse_info;
3333
import embedding_cast;
3434
import logger;

src/parser/statement/compact_statement.cppm

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,5 +22,4 @@ namespace infinity {
2222
export using infinity::CompactStatementType;
2323
export using infinity::CompactStatement;
2424
export using infinity::ManualCompactStatement;
25-
export using infinity::AutoCompactStatement;
2625
}; // namespace infinity

src/parser/statement/compact_statement.h

Lines changed: 0 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -20,8 +20,6 @@
2020

2121
namespace infinity {
2222

23-
struct SegmentEntry;
24-
2523
enum class CompactStatementType { kManual, kAuto, kInvalid };
2624

2725
class CompactStatement : public BaseStatement {
@@ -41,17 +39,6 @@ class ManualCompactStatement : public CompactStatement {
4139
public:
4240
ManualCompactStatement(const std::string &db_name, const std::string &table_name)
4341
: CompactStatement{CompactStatementType::kManual, db_name, table_name} {}
44-
45-
public:
46-
};
47-
48-
struct AutoCompactStatement : public CompactStatement {
49-
public:
50-
AutoCompactStatement(const std::string &db_name, const std::string &table_name, std::vector<SegmentEntry *> segments_to_compact)
51-
: CompactStatement{CompactStatementType::kAuto, db_name, table_name}, segments_to_compact_(std::move(segments_to_compact)) {}
52-
53-
public:
54-
std::vector<SegmentEntry *> segments_to_compact_;
5542
};
5643

5744
} // namespace infinity

src/parser/type/complex/varchar.h

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -19,8 +19,6 @@
1919

2020
namespace infinity {
2121

22-
struct FixHeapManager;
23-
2422
// varchar related constants
2523
constexpr uint64_t VARCHAR_PREFIX_LENGTH = 5;
2624
constexpr uint64_t VARCHAR_INLINE_LENGTH = 13;

src/planner/node/logical_command.cppm

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -27,8 +27,6 @@ import data_type;
2727

2828
namespace infinity {
2929

30-
struct TableEntry;
31-
3230
export class LogicalCommand : public LogicalNode {
3331
public:
3432
LogicalCommand(u64 node_id, SharedPtr<CommandInfo> command_info)

src/planner/query_binder.cpp

Lines changed: 2 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1123,13 +1123,8 @@ UniquePtr<BoundUpdateStatement> QueryBinder::BindUpdate(const UpdateStatement &s
11231123

11241124
UniquePtr<BoundCompactStatement> QueryBinder::BindCompact(const CompactStatement &statement) {
11251125
SharedPtr<BaseTableRef> base_table_ref = nullptr;
1126-
if (statement.compact_type_ == CompactStatementType::kManual) {
1127-
const auto &compact_statement = static_cast<const ManualCompactStatement &>(statement);
1128-
base_table_ref = GetTableRef(compact_statement.db_name_, compact_statement.table_name_);
1129-
} else {
1130-
const auto &compact_statement = static_cast<const AutoCompactStatement &>(statement);
1131-
base_table_ref = GetTableRef(compact_statement.db_name_, compact_statement.table_name_);
1132-
}
1126+
const auto &compact_statement = static_cast<const ManualCompactStatement &>(statement);
1127+
base_table_ref = GetTableRef(compact_statement.db_name_, compact_statement.table_name_);
11331128
return MakeUnique<BoundCompactStatement>(bind_context_ptr_, base_table_ref, statement.compact_type_);
11341129
}
11351130

src/storage/column_vector/column_vector.cpp

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,6 @@ import infinity_exception;
2828
import default_values;
2929
import roaring_bitmap;
3030
import vector_buffer;
31-
import fix_heap;
3231
import serialize;
3332
import third_party;
3433
import logger;

src/storage/column_vector/column_vector.cppm

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,6 @@ import value;
3030
import status;
3131
import third_party;
3232
import infinity_exception;
33-
import fix_heap;
3433
import internal_types;
3534
import data_type;
3635
import embedding_info;

0 commit comments

Comments
 (0)