Skip to content

Commit fc108f7

Browse files
AlnenAlnen
committed
Fixed PR comments ydb-platform#4 
1 parent 249a4cc commit fc108f7

13 files changed

+41
-76
lines changed

‎ydb/core/protos/counters_schemeshard.proto

+1-7
Original file line numberDiff line numberDiff line change
@@ -194,10 +194,7 @@ enum ESimpleCounters {
194194
COUNTER_IN_FLIGHT_OPS_TxAlterView = 156 [(CounterOpts) = {Name: "InFlightOps/AlterView"}];
195195
COUNTER_IN_FLIGHT_OPS_TxDropView = 157 [(CounterOpts) = {Name: "InFlightOps/DropView"}];
196196

197-
COUNTER_IN_FLIGHT_OPS_TxReplaceExternalTable = 158 [(CounterOpts) = {Name: "InFlightOps/ReplaceExternalTable"}];
198-
COUNTER_IN_FLIGHT_OPS_TxReplaceExternalDataSource = 159 [(CounterOpts) = {Name: "InFlightOps/ReplaceExternalDataSource"}];
199-
200-
COUNTER_GRAPHSHARD_COUNT = 160 [(CounterOpts) = {Name: "GraphShards"}];
197+
COUNTER_GRAPHSHARD_COUNT = 158 [(CounterOpts) = {Name: "GraphShards"}];
201198
}
202199

203200
enum ECumulativeCounters {
@@ -318,9 +315,6 @@ enum ECumulativeCounters {
318315
COUNTER_FINISHED_OPS_TxCreateView = 95 [(CounterOpts) = {Name: "FinishedOps/CreateView"}];
319316
COUNTER_FINISHED_OPS_TxDropView = 96 [(CounterOpts) = {Name: "FinishedOps/DropView"}];
320317
COUNTER_FINISHED_OPS_TxAlterView = 97 [(CounterOpts) = {Name: "FinishedOps/AlterView"}];
321-
322-
COUNTER_FINISHED_OPS_TxReplaceExternalTable = 98 [(CounterOpts) = {Name: "FinishedOps/ReplaceExternalTable"}];
323-
COUNTER_FINISHED_OPS_TxReplaceExternalDataSource = 99 [(CounterOpts) = {Name: "FinishedOps/ReplaceExternalDataSource"}];
324318
}
325319

326320
enum EPercentileCounters {

‎ydb/core/protos/flat_scheme_op.proto

-3
Original file line numberDiff line numberDiff line change
@@ -1431,9 +1431,6 @@ enum EOperationType {
14311431
ESchemeOpCreateView = 93;
14321432
ESchemeOpAlterView = 94;
14331433
ESchemeOpDropView = 95;
1434-
1435-
ESchemeOpReplaceExternalDataSource = 96;
1436-
ESchemeOpReplaceExternalTable = 97;
14371434
}
14381435

14391436
message TApplyIf {

‎ydb/core/tx/schemeshard/schemeshard__operation.cpp

+2-10
Original file line numberDiff line numberDiff line change
@@ -1061,18 +1061,14 @@ ISubOperation::TPtr TOperation::RestorePart(TTxState::ETxType txType, TTxState::
10611061
return CreateNewExternalTable(NextPartId(), txState);
10621062
case TTxState::ETxType::TxDropExternalTable:
10631063
return CreateDropExternalTable(NextPartId(), txState);
1064-
case TTxState::ETxType::TxReplaceExternalTable:
1065-
return CreateReplaceExternalTable(NextPartId(), txState);
10661064
case TTxState::ETxType::TxAlterExternalTable:
1067-
Y_ABORT("TODO: implement");
1065+
return CreateAlterExternalTable(NextPartId(), txState);
10681066
case TTxState::ETxType::TxCreateExternalDataSource:
10691067
return CreateNewExternalDataSource(NextPartId(), txState);
10701068
case TTxState::ETxType::TxDropExternalDataSource:
10711069
return CreateDropExternalDataSource(NextPartId(), txState);
1072-
case TTxState::ETxType::TxReplaceExternalDataSource:
1073-
return CreateReplaceExternalDataSource(NextPartId(), txState);
10741070
case TTxState::ETxType::TxAlterExternalDataSource:
1075-
Y_ABORT("TODO: implement");
1071+
return CreateAlterExternalDataSource(NextPartId(), txState);
10761072

10771073
// View
10781074
case TTxState::ETxType::TxCreateView:
@@ -1285,8 +1281,6 @@ ISubOperation::TPtr TOperation::ConstructPart(NKikimrSchemeOp::EOperationType op
12851281
return CreateDropBlobDepot(NextPartId(), tx);
12861282

12871283
// ExternalTable
1288-
case NKikimrSchemeOp::EOperationType::ESchemeOpReplaceExternalTable:
1289-
Y_ABORT("this operation must be constructed by ESchemeOpCreateExternalTable");
12901284
case NKikimrSchemeOp::EOperationType::ESchemeOpCreateExternalTable:
12911285
Y_ABORT("operation is handled before");
12921286
case NKikimrSchemeOp::EOperationType::ESchemeOpDropExternalTable:
@@ -1295,8 +1289,6 @@ ISubOperation::TPtr TOperation::ConstructPart(NKikimrSchemeOp::EOperationType op
12951289
Y_ABORT("TODO: implement");
12961290

12971291
// ExternalDataSource
1298-
case NKikimrSchemeOp::EOperationType::ESchemeOpReplaceExternalDataSource:
1299-
Y_ABORT("this operation must be constructed by ESchemeOpCreateExternalTable");
13001292
case NKikimrSchemeOp::EOperationType::ESchemeOpCreateExternalDataSource:
13011293
Y_ABORT("operation is handled before");
13021294
case NKikimrSchemeOp::EOperationType::ESchemeOpDropExternalDataSource:

‎ydb/core/tx/schemeshard/schemeshard__operation_replace_external_data_source.cpp renamed to ‎ydb/core/tx/schemeshard/schemeshard__operation_alter_external_data_source.cpp

+13-13
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@ class TPropose: public TSubOperationState {
1616

1717
TString DebugHint() const override {
1818
return TStringBuilder()
19-
<< "TReplaceExternalDataSource TPropose"
19+
<< "TAlterExternalDataSource TPropose"
2020
<< ", operationId: " << OperationId;
2121
}
2222

@@ -34,7 +34,7 @@ class TPropose: public TSubOperationState {
3434

3535
const TTxState* txState = context.SS->FindTx(OperationId);
3636
Y_ABORT_UNLESS(txState);
37-
Y_ABORT_UNLESS(txState->TxType == TTxState::TxReplaceExternalDataSource);
37+
Y_ABORT_UNLESS(txState->TxType == TTxState::TxAlterExternalDataSource);
3838

3939
const auto pathId = txState->TargetPathId;
4040
const auto path = TPath::Init(pathId, context.SS);
@@ -56,14 +56,14 @@ class TPropose: public TSubOperationState {
5656

5757
const TTxState* txState = context.SS->FindTx(OperationId);
5858
Y_ABORT_UNLESS(txState);
59-
Y_ABORT_UNLESS(txState->TxType == TTxState::TxReplaceExternalDataSource);
59+
Y_ABORT_UNLESS(txState->TxType == TTxState::TxAlterExternalDataSource);
6060

6161
context.OnComplete.ProposeToCoordinator(OperationId, txState->TargetPathId, TStepId(0));
6262
return false;
6363
}
6464
};
6565

66-
class TReplaceExternalDataSource : public TSubOperation {
66+
class TAlterExternalDataSource : public TSubOperation {
6767
static TTxState::ETxState NextState() { return TTxState::Propose; }
6868

6969
TTxState::ETxState NextState(TTxState::ETxState state) const override {
@@ -152,7 +152,7 @@ class TReplaceExternalDataSource : public TSubOperation {
152152
void CreateTransaction(const TOperationContext& context,
153153
const TPathId& externalDataSourcePathId) const {
154154
TTxState& txState = context.SS->CreateTx(OperationId,
155-
TTxState::TxReplaceExternalDataSource,
155+
TTxState::TxAlterExternalDataSource,
156156
externalDataSourcePathId);
157157
txState.Shards.clear();
158158
}
@@ -207,7 +207,7 @@ class TReplaceExternalDataSource : public TSubOperation {
207207
Transaction.GetCreateExternalDataSource();
208208
const TString& name = externalDataSourceDescription.GetName();
209209

210-
LOG_N("TReplaceExternalDataSource Propose"
210+
LOG_N("TAlterExternalDataSource Propose"
211211
<< ": opId# " << OperationId << ", path# " << parentPathStr << "/" << name);
212212

213213
auto result = MakeHolder<TProposeResponse>(NKikimrScheme::StatusAccepted,
@@ -258,13 +258,13 @@ class TReplaceExternalDataSource : public TSubOperation {
258258
}
259259

260260
void AbortPropose(TOperationContext& context) override {
261-
LOG_N("TReplaceExternalDataSource AbortPropose"
261+
LOG_N("TAlterExternalDataSource AbortPropose"
262262
<< ": opId# " << OperationId);
263-
Y_ABORT("no AbortPropose for TReplaceExternalDataSource");
263+
Y_ABORT("no AbortPropose for TAlterExternalDataSource");
264264
}
265265

266266
void AbortUnsafe(TTxId forceDropTxId, TOperationContext& context) override {
267-
LOG_N("TReplaceExternalDataSource AbortUnsafe"
267+
LOG_N("TAlterExternalDataSource AbortUnsafe"
268268
<< ": opId# " << OperationId << ", txId# " << forceDropTxId);
269269
context.OnComplete.DoneOperation(OperationId);
270270
}
@@ -274,13 +274,13 @@ class TReplaceExternalDataSource : public TSubOperation {
274274

275275
namespace NKikimr::NSchemeShard {
276276

277-
ISubOperation::TPtr CreateReplaceExternalDataSource(TOperationId id, const TTxTransaction& tx) {
278-
return MakeSubOperation<TReplaceExternalDataSource>(id, tx);
277+
ISubOperation::TPtr CreateAlterExternalDataSource(TOperationId id, const TTxTransaction& tx) {
278+
return MakeSubOperation<TAlterExternalDataSource>(id, tx);
279279
}
280280

281-
ISubOperation::TPtr CreateReplaceExternalDataSource(TOperationId id, TTxState::ETxState state) {
281+
ISubOperation::TPtr CreateAlterExternalDataSource(TOperationId id, TTxState::ETxState state) {
282282
Y_ABORT_UNLESS(state != TTxState::Invalid);
283-
return MakeSubOperation<TReplaceExternalDataSource>(id, state);
283+
return MakeSubOperation<TAlterExternalDataSource>(id, state);
284284
}
285285

286286
}

‎ydb/core/tx/schemeshard/schemeshard__operation_replace_external_table.cpp renamed to ‎ydb/core/tx/schemeshard/schemeshard__operation_alter_external_table.cpp

+13-13
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@ class TPropose: public TSubOperationState {
1818

1919
TString DebugHint() const override {
2020
return TStringBuilder()
21-
<< "TReplaceExternalTable TPropose"
21+
<< "TAlterExternalTable TPropose"
2222
<< ", operationId: " << OperationId;
2323
}
2424

@@ -59,7 +59,7 @@ class TPropose: public TSubOperationState {
5959

6060
const TTxState* txState = context.SS->FindTx(OperationId);
6161
Y_ABORT_UNLESS(txState);
62-
Y_ABORT_UNLESS(txState->TxType == TTxState::TxReplaceExternalTable);
62+
Y_ABORT_UNLESS(txState->TxType == TTxState::TxAlterExternalTable);
6363

6464
const auto pathId = txState->TargetPathId;
6565
const auto dataSourcePathId = txState->SourcePathId;
@@ -88,15 +88,15 @@ class TPropose: public TSubOperationState {
8888

8989
const TTxState* txState = context.SS->FindTx(OperationId);
9090
Y_ABORT_UNLESS(txState);
91-
Y_ABORT_UNLESS(txState->TxType == TTxState::TxReplaceExternalTable);
91+
Y_ABORT_UNLESS(txState->TxType == TTxState::TxAlterExternalTable);
9292

9393
context.OnComplete.ProposeToCoordinator(OperationId, txState->TargetPathId, TStepId(0));
9494
return false;
9595
}
9696
};
9797

9898

99-
class TReplacetExternalTable: public TSubOperation {
99+
class TAlterExternalTable: public TSubOperation {
100100
private:
101101
bool IsSameDataSource = true;
102102
TPathId OldDataSourcePathId = InvalidPathId;
@@ -220,7 +220,7 @@ class TReplacetExternalTable: public TSubOperation {
220220
const TPathId& externalTablePathId,
221221
const TPathId& externalDataSourcePathId) const {
222222
TTxState& txState = context.SS->CreateTx(OperationId,
223-
TTxState::TxReplaceExternalTable,
223+
TTxState::TxAlterExternalTable,
224224
externalTablePathId,
225225
externalDataSourcePathId);
226226
txState.Shards.clear();
@@ -301,7 +301,7 @@ class TReplacetExternalTable: public TSubOperation {
301301
const auto& externalTableDescription = Transaction.GetCreateExternalTable();
302302
const TString& name = externalTableDescription.GetName();
303303

304-
LOG_N("TReplaceExternalTable Propose"
304+
LOG_N("TAlterExternalTable Propose"
305305
<< ": opId# " << OperationId
306306
<< ", path# " << parentPathStr << "/" << name << ", ReplaceIfExists:" << externalTableDescription.GetReplaceIfExists());
307307

@@ -392,13 +392,13 @@ class TReplacetExternalTable: public TSubOperation {
392392
}
393393

394394
void AbortPropose(TOperationContext& context) override {
395-
LOG_N("TReplaceExternalTable AbortPropose"
395+
LOG_N("TAlterExternalTable AbortPropose"
396396
<< ": opId# " << OperationId);
397-
Y_ABORT("no AbortPropose for TReplaceExternalTable");
397+
Y_ABORT("no AbortPropose for TAlterExternalTable");
398398
}
399399

400400
void AbortUnsafe(TTxId forceDropTxId, TOperationContext& context) override {
401-
LOG_N("TReplaceExternalTable AbortUnsafe"
401+
LOG_N("TAlterExternalTable AbortUnsafe"
402402
<< ": opId# " << OperationId
403403
<< ", txId# " << forceDropTxId);
404404
context.OnComplete.DoneOperation(OperationId);
@@ -409,13 +409,13 @@ class TReplacetExternalTable: public TSubOperation {
409409

410410
namespace NKikimr::NSchemeShard {
411411

412-
ISubOperation::TPtr CreateReplaceExternalTable(TOperationId id, const TTxTransaction& tx) {
413-
return MakeSubOperation<TReplacetExternalTable>(std::move(id), tx);
412+
ISubOperation::TPtr CreateAlterExternalTable(TOperationId id, const TTxTransaction& tx) {
413+
return MakeSubOperation<TAlterExternalTable>(std::move(id), tx);
414414
}
415415

416-
ISubOperation::TPtr CreateReplaceExternalTable(TOperationId id, TTxState::ETxState state) {
416+
ISubOperation::TPtr CreateAlterExternalTable(TOperationId id, TTxState::ETxState state) {
417417
Y_ABORT_UNLESS(state != TTxState::Invalid);
418-
return MakeSubOperation<TReplacetExternalTable>(std::move(id), state);
418+
return MakeSubOperation<TAlterExternalTable>(std::move(id), state);
419419
}
420420

421421
}

‎ydb/core/tx/schemeshard/schemeshard__operation_create_external_data_source.cpp

+1-3
Original file line numberDiff line numberDiff line change
@@ -329,16 +329,14 @@ TVector<ISubOperation::TPtr> CreateNewExternalDataSource(TOperationId id,
329329
}
330330
}
331331

332-
333-
334332
if (replaceIfExists) {
335333
const TPath dstPath = parentPath.Child(name);
336334
const auto isAlreadyExists =
337335
dstPath.Check()
338336
.IsResolved()
339337
.NotUnderDeleting();
340338
if (isAlreadyExists) {
341-
return {CreateReplaceExternalDataSource(id, tx)};
339+
return {CreateAlterExternalDataSource(id, tx)};
342340
}
343341
}
344342

‎ydb/core/tx/schemeshard/schemeshard__operation_create_external_table.cpp

+1-1
Original file line numberDiff line numberDiff line change
@@ -429,7 +429,7 @@ TVector<ISubOperation::TPtr> CreateNewExternalTable(TOperationId id, const TTxTr
429429
.IsResolved()
430430
.NotUnderDeleting();
431431
if (isAlreadyExists) {
432-
return {CreateReplaceExternalTable(id, tx)};
432+
return {CreateAlterExternalTable(id, tx)};
433433
}
434434
}
435435

‎ydb/core/tx/schemeshard/schemeshard__operation_part.h

+6-6
Original file line numberDiff line numberDiff line change
@@ -371,9 +371,9 @@ ISubOperation::TPtr CreateUpdateMainTableOnIndexMove(TOperationId id, TTxState::
371371
// Create
372372
TVector<ISubOperation::TPtr> CreateNewExternalTable(TOperationId id, const TTxTransaction& tx, TOperationContext& context);
373373
ISubOperation::TPtr CreateNewExternalTable(TOperationId id, TTxState::ETxState state);
374-
// Replace
375-
ISubOperation::TPtr CreateReplaceExternalTable(TOperationId id, const TTxTransaction& tx);
376-
ISubOperation::TPtr CreateReplaceExternalTable(TOperationId id, TTxState::ETxState state);
374+
// Alter
375+
ISubOperation::TPtr CreateAlterExternalTable(TOperationId id, const TTxTransaction& tx);
376+
ISubOperation::TPtr CreateAlterExternalTable(TOperationId id, TTxState::ETxState state);
377377
// Drop
378378
ISubOperation::TPtr CreateDropExternalTable(TOperationId id, const TTxTransaction& tx);
379379
ISubOperation::TPtr CreateDropExternalTable(TOperationId id, TTxState::ETxState state);
@@ -382,9 +382,9 @@ ISubOperation::TPtr CreateDropExternalTable(TOperationId id, TTxState::ETxState
382382
// Create
383383
TVector<ISubOperation::TPtr> CreateNewExternalDataSource(TOperationId id, const TTxTransaction& tx, TOperationContext& context);
384384
ISubOperation::TPtr CreateNewExternalDataSource(TOperationId id, TTxState::ETxState state);
385-
// Replace
386-
ISubOperation::TPtr CreateReplaceExternalDataSource(TOperationId id, const TTxTransaction& tx);
387-
ISubOperation::TPtr CreateReplaceExternalDataSource(TOperationId id, TTxState::ETxState state);
385+
// Alter
386+
ISubOperation::TPtr CreateAlterExternalDataSource(TOperationId id, const TTxTransaction& tx);
387+
ISubOperation::TPtr CreateAlterExternalDataSource(TOperationId id, TTxState::ETxState state);
388388
// Drop
389389
ISubOperation::TPtr CreateDropExternalDataSource(TOperationId id, const TTxTransaction& tx);
390390
ISubOperation::TPtr CreateDropExternalDataSource(TOperationId id, TTxState::ETxState state);

‎ydb/core/tx/schemeshard/schemeshard_audit_log_fragment.cpp

-4
Original file line numberDiff line numberDiff line change
@@ -208,14 +208,12 @@ TString DefineUserOperationName(const NKikimrSchemeOp::TModifyScheme& tx) {
208208
return "ALTER BLOB DEPOT";
209209
case NKikimrSchemeOp::EOperationType::ESchemeOpDropBlobDepot:
210210
return "DROP BLOB DEPOT";
211-
case NKikimrSchemeOp::EOperationType::ESchemeOpReplaceExternalTable:
212211
case NKikimrSchemeOp::EOperationType::ESchemeOpCreateExternalTable:
213212
return "CREATE EXTERNAL TABLE";
214213
case NKikimrSchemeOp::EOperationType::ESchemeOpDropExternalTable:
215214
return "DROP EXTERNAL TABLE";
216215
case NKikimrSchemeOp::EOperationType::ESchemeOpAlterExternalTable:
217216
return "ALTER EXTERNAL TABLE";
218-
case NKikimrSchemeOp::EOperationType::ESchemeOpReplaceExternalDataSource:
219217
case NKikimrSchemeOp::EOperationType::ESchemeOpCreateExternalDataSource:
220218
return "CREATE EXTERNAL DATA SOURCE";
221219
case NKikimrSchemeOp::EOperationType::ESchemeOpDropExternalDataSource:
@@ -489,7 +487,6 @@ TVector<TString> ExtractChangingPaths(const NKikimrSchemeOp::TModifyScheme& tx)
489487
result.emplace_back(NKikimr::JoinPath({tx.GetMoveIndex().GetTablePath(), tx.GetMoveIndex().GetSrcPath()}));
490488
result.emplace_back(NKikimr::JoinPath({tx.GetMoveIndex().GetTablePath(), tx.GetMoveIndex().GetDstPath()}));
491489
break;
492-
case NKikimrSchemeOp::EOperationType::ESchemeOpReplaceExternalTable:
493490
case NKikimrSchemeOp::EOperationType::ESchemeOpCreateExternalTable:
494491
result.emplace_back(NKikimr::JoinPath({tx.GetWorkingDir(), tx.GetCreateExternalTable().GetName()}));
495492
break;
@@ -499,7 +496,6 @@ TVector<TString> ExtractChangingPaths(const NKikimrSchemeOp::TModifyScheme& tx)
499496
case NKikimrSchemeOp::EOperationType::ESchemeOpAlterExternalTable:
500497
// TODO: unimplemented
501498
break;
502-
case NKikimrSchemeOp::EOperationType::ESchemeOpReplaceExternalDataSource:
503499
case NKikimrSchemeOp::EOperationType::ESchemeOpCreateExternalDataSource:
504500
result.emplace_back(NKikimr::JoinPath({tx.GetWorkingDir(), tx.GetCreateExternalDataSource().GetName()}));
505501
break;

‎ydb/core/tx/schemeshard/schemeshard_impl.cpp

-2
Original file line numberDiff line numberDiff line change
@@ -1455,8 +1455,6 @@ TPathElement::EPathState TSchemeShard::CalcPathState(TTxState::ETxType txType, T
14551455
case TTxState::TxUpdateMainTableOnIndexMove:
14561456
case TTxState::TxAlterExternalTable:
14571457
case TTxState::TxAlterExternalDataSource:
1458-
case TTxState::TxReplaceExternalTable:
1459-
case TTxState::TxReplaceExternalDataSource:
14601458
case TTxState::TxAlterView:
14611459
return TPathElement::EPathState::EPathStateAlter;
14621460
case TTxState::TxDropTable:

‎ydb/core/tx/schemeshard/schemeshard_tx_infly.h

-10
Original file line numberDiff line numberDiff line change
@@ -129,8 +129,6 @@ struct TTxState {
129129
item(TxCreateView, 83) \
130130
item(TxAlterView, 84) \
131131
item(TxDropView, 85) \
132-
item(TxReplaceExternalDataSource, 86) \
133-
item(TxReplaceExternalTable, 87) \
134132

135133
// TX_STATE_TYPE_ENUM
136134

@@ -407,8 +405,6 @@ struct TTxState {
407405
case TxAlterBlobDepot:
408406
case TxAlterExternalTable:
409407
case TxAlterExternalDataSource:
410-
case TxReplaceExternalDataSource:
411-
case TxReplaceExternalTable:
412408
case TxAlterView:
413409
return false;
414410
case TxMoveTable:
@@ -506,8 +502,6 @@ struct TTxState {
506502
case TxAlterBlobDepot:
507503
case TxAlterExternalTable:
508504
case TxAlterExternalDataSource:
509-
case TxReplaceExternalDataSource:
510-
case TxReplaceExternalTable:
511505
case TxAlterView:
512506
return false;
513507
case TxMoveTable:
@@ -608,8 +602,6 @@ struct TTxState {
608602
case TxAlterBlobDepot:
609603
case TxAlterExternalTable:
610604
case TxAlterExternalDataSource:
611-
case TxReplaceExternalDataSource:
612-
case TxReplaceExternalTable:
613605
case TxAlterView:
614606
return false;
615607
case TxInvalid:
@@ -706,10 +698,8 @@ struct TTxState {
706698
case NKikimrSchemeOp::ESchemeOpDeallocatePersQueueGroup: return TxInvalid;
707699
case NKikimrSchemeOp::ESchemeOpCreateExternalTable: return TxCreateExternalTable;
708700
case NKikimrSchemeOp::ESchemeOpAlterExternalTable: return TxAlterExternalTable;
709-
case NKikimrSchemeOp::ESchemeOpReplaceExternalTable: return TxReplaceExternalTable;
710701
case NKikimrSchemeOp::ESchemeOpCreateExternalDataSource: return TxCreateExternalDataSource;
711702
case NKikimrSchemeOp::ESchemeOpAlterExternalDataSource: return TxAlterExternalDataSource;
712-
case NKikimrSchemeOp::ESchemeOpReplaceExternalDataSource: return TxReplaceExternalDataSource;
713703
case NKikimrSchemeOp::ESchemeOpCreateView: return TxCreateView;
714704
case NKikimrSchemeOp::ESchemeOpAlterView: return TxAlterView;
715705
case NKikimrSchemeOp::ESchemeOpDropView: return TxDropView;

0 commit comments

Comments
 (0)