@@ -11,14 +11,14 @@ SRCS(
11
11
build_distributed_erase_tx_out_rs_unit.cpp
12
12
build_index.cpp
13
13
build_kqp_data_tx_out_rs_unit.cpp
14
- build_write_out_rs_unit.cpp
15
14
build_scheme_tx_out_rs_unit.cpp
15
+ build_write_out_rs_unit.cpp
16
16
cdc_stream_heartbeat.cpp
17
17
cdc_stream_scan.cpp
18
+ change_collector.cpp
18
19
change_collector_async_index.cpp
19
20
change_collector_base.cpp
20
21
change_collector_cdc_stream.cpp
21
- change_collector.cpp
22
22
change_exchange.cpp
23
23
change_exchange_split.cpp
24
24
change_record.cpp
@@ -42,96 +42,96 @@ SRCS(
42
42
create_persistent_snapshot_unit.cpp
43
43
create_table_unit.cpp
44
44
create_volatile_snapshot_unit.cpp
45
+ datashard.cpp
46
+ datashard.h
45
47
datashard__cancel_tx_proposal.cpp
46
- datashard__column_stats.cpp
47
- datashard__compact_borrowed.cpp
48
- datashard__compaction.cpp
49
48
datashard__cleanup_borrowed.cpp
50
49
datashard__cleanup_in_rs.cpp
51
50
datashard__cleanup_tx.cpp
51
+ datashard__column_stats.cpp
52
+ datashard__compact_borrowed.cpp
53
+ datashard__compaction.cpp
52
54
datashard__conditional_erase_rows.cpp
53
55
datashard__engine_host.cpp
54
56
datashard__engine_host.h
55
57
datashard__get_state_tx.cpp
56
- datashard__schema_changed.cpp
57
- datashard__migrate_schemeshard.cpp
58
58
datashard__init.cpp
59
- datashard__monitoring.cpp
59
+ datashard__kqp_scan.cpp
60
+ datashard__migrate_schemeshard.cpp
60
61
datashard__mon_reset_schema_version.cpp
62
+ datashard__monitoring.cpp
63
+ datashard__object_storage_listing.cpp
61
64
datashard__op_rows.cpp
62
65
datashard__plan_step.cpp
63
66
datashard__progress_resend_rs.cpp
64
67
datashard__progress_tx.cpp
65
68
datashard__propose_tx_base.cpp
66
- datashard__readset.cpp
67
- datashard__read_iterator.cpp
68
69
datashard__read_columns.cpp
70
+ datashard__read_iterator.cpp
71
+ datashard__readset.cpp
69
72
datashard__s3_download_txs.cpp
70
73
datashard__s3_upload_txs.cpp
71
- datashard__object_storage_listing.cpp
72
- datashard__kqp_scan.cpp
74
+ datashard__schema_changed.cpp
73
75
datashard__snapshot_txs.cpp
74
76
datashard__stats.cpp
75
- datashard__store_table_path.cpp
76
77
datashard__store_scan_state.cpp
78
+ datashard__store_table_path.cpp
77
79
datashard__write.cpp
80
+ datashard_active_transaction.cpp
81
+ datashard_active_transaction.h
78
82
datashard_change_receiving.cpp
79
83
datashard_change_sender_activation.cpp
80
84
datashard_change_sending.cpp
81
- datashard_loans.cpp
82
- datashard_locks_db.cpp
83
- datashard_locks_db.h
84
- datashard_split_dst.cpp
85
- datashard_split_src.cpp
86
- datashard_switch_mvcc_state.cpp
87
- datashard_trans_queue.cpp
88
- datashard_trans_queue.h
89
- datashard_outreadset.cpp
90
- datashard_outreadset.h
91
- datashard_active_transaction.cpp
92
- datashard_active_transaction.h
93
85
datashard_common_upload.cpp
86
+ datashard_dep_tracker.cpp
87
+ datashard_dep_tracker.h
88
+ datashard_direct_erase.cpp
94
89
datashard_direct_transaction.cpp
95
90
datashard_direct_transaction.h
96
- datashard_direct_erase.cpp
97
91
datashard_direct_upload.cpp
98
92
datashard_distributed_erase.cpp
99
93
datashard_failpoints.cpp
100
94
datashard_failpoints.h
101
- datashard_dep_tracker.cpp
102
- datashard_dep_tracker.h
103
- datashard_overload.cpp
104
- datashard_pipeline.cpp
105
- datashard_pipeline.h
106
- datashard_s3_downloads.cpp
107
- datashard_s3_uploads.cpp
108
- datashard_s3_upload_rows.cpp
109
- datashard_schema_snapshots.cpp
110
- datashard_snapshots.cpp
111
- datashard_user_db.cpp
112
- datashard_user_db.h
113
- datashard_user_table.cpp
114
- datashard_user_table.h
115
95
datashard_impl.h
96
+ datashard_kqp.cpp
97
+ datashard_kqp.h
116
98
datashard_kqp_compute.cpp
117
99
datashard_kqp_compute.h
100
+ datashard_kqp_delete_rows.cpp
118
101
datashard_kqp_effects.cpp
119
102
datashard_kqp_lookup_table.cpp
120
103
datashard_kqp_read_table.cpp
121
104
datashard_kqp_upsert_rows.cpp
122
- datashard_kqp_delete_rows.cpp
123
- datashard_kqp.cpp
124
- datashard_kqp.h
105
+ datashard_loans.cpp
106
+ datashard_locks_db.cpp
107
+ datashard_locks_db.h
108
+ datashard_outreadset.cpp
109
+ datashard_outreadset.h
110
+ datashard_overload.cpp
111
+ datashard_pipeline.cpp
112
+ datashard_pipeline.h
125
113
datashard_read_operation.h
126
114
datashard_repl_apply.cpp
127
115
datashard_repl_offsets.cpp
128
116
datashard_repl_offsets_client.cpp
129
117
datashard_repl_offsets_server.cpp
118
+ datashard_s3_downloads.cpp
119
+ datashard_s3_upload_rows.cpp
120
+ datashard_s3_uploads.cpp
121
+ datashard_schema_snapshots.cpp
122
+ datashard_snapshots.cpp
123
+ datashard_split_dst.cpp
124
+ datashard_split_src.cpp
130
125
datashard_subdomain_path_id.cpp
131
- datashard_write_operation.cpp
126
+ datashard_switch_mvcc_state.cpp
127
+ datashard_trans_queue.cpp
128
+ datashard_trans_queue.h
132
129
datashard_txs.h
133
- datashard.cpp
134
- datashard.h
130
+ datashard_user_db.cpp
131
+ datashard_user_db.h
132
+ datashard_user_table.cpp
133
+ datashard_user_table.h
134
+ datashard_write_operation.cpp
135
135
defs.h
136
136
direct_tx_unit.cpp
137
137
drop_cdc_stream_unit.cpp
@@ -142,10 +142,10 @@ SRCS(
142
142
erase_rows_condition.cpp
143
143
execute_commit_writes_tx_unit.cpp
144
144
execute_data_tx_unit.cpp
145
- execute_write_unit.cpp
146
145
execute_distributed_erase_tx_unit.cpp
147
146
execute_kqp_data_tx_unit.cpp
148
147
execute_kqp_scan_tx_unit.cpp
148
+ execute_write_unit.cpp
149
149
execution_unit.cpp
150
150
execution_unit.h
151
151
execution_unit_ctors.h
@@ -175,40 +175,40 @@ SRCS(
175
175
operation.h
176
176
plan_queue_unit.cpp
177
177
prepare_data_tx_in_rs_unit.cpp
178
- prepare_write_tx_in_rs_unit.cpp
179
178
prepare_distributed_erase_tx_in_rs_unit.cpp
180
179
prepare_kqp_data_tx_in_rs_unit.cpp
181
180
prepare_scheme_tx_in_rs_unit.cpp
181
+ prepare_write_tx_in_rs_unit.cpp
182
182
probes.cpp
183
183
progress_queue.h
184
184
protect_scheme_echoes_unit.cpp
185
+ range_ops.cpp
186
+ read_iterator.h
185
187
read_op_unit.cpp
186
- read_table_scan.h
187
188
read_table_scan.cpp
189
+ read_table_scan.h
188
190
read_table_scan_unit.cpp
189
191
receive_snapshot_cleanup_unit.cpp
190
192
receive_snapshot_unit.cpp
191
193
remove_lock_change_records.cpp
192
194
remove_locks.cpp
193
195
remove_schema_snapshots.cpp
194
- range_ops.cpp
195
- read_iterator.h
196
196
restore_unit.cpp
197
197
sample_k.cpp
198
198
scan_common.cpp
199
199
setup_sys_locks.h
200
200
store_and_send_out_rs_unit.cpp
201
- store_and_send_write_out_rs_unit.cpp
201
+ store_and_send_write_out_rs_unit.cpp
202
202
store_commit_writes_tx_unit.cpp
203
203
store_data_tx_unit.cpp
204
- store_write_unit.cpp
205
204
store_distributed_erase_tx_unit.cpp
206
205
store_scheme_tx_unit.cpp
207
206
store_snapshot_tx_unit.cpp
207
+ store_write_unit.cpp
208
+ upload_stats.cpp
208
209
volatile_tx.cpp
209
210
wait_for_plan_unit.cpp
210
211
wait_for_stream_clearance_unit.cpp
211
- upload_stats.cpp
212
212
)
213
213
214
214
GENERATE_ENUM_SERIALIZATION(backup_restore_traits.h)
0 commit comments