Skip to content

Commit 6b1e302

Browse files
committed
replace "indexImplTable" with NTableIndex::ImplTable
1 parent e93969d commit 6b1e302

File tree

4 files changed

+8
-6
lines changed

4 files changed

+8
-6
lines changed

ydb/core/grpc_services/rpc_describe_table.cpp

+2-1
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,7 @@
66

77
#include "service_table.h"
88
#include "rpc_common/rpc_common.h"
9+
#include <ydb/core/base/table_index.h>
910
#include <ydb/core/tx/schemeshard/schemeshard.h>
1011
#include <ydb/core/ydb_convert/table_description.h>
1112
#include <ydb/core/ydb_convert/ydb_convert.h>
@@ -153,7 +154,7 @@ class TDescribeTableRPC : public TRpcSchemeRequestActor<TDescribeTableRPC, TEvDe
153154
record->MutableOptions()->SetReturnPartitionStats(true);
154155
}
155156

156-
if (AppData(ctx)->AllowPrivateTableDescribeForTest || path.EndsWith("/indexImplTable")) {
157+
if (AppData(ctx)->AllowPrivateTableDescribeForTest || path.EndsWith(TStringBuilder() << "/" << NTableIndex::ImplTable)) {
157158
record->MutableOptions()->SetShowPrivateTable(true);
158159
}
159160

ydb/core/kqp/gateway/utils/scheme_helpers.cpp

+2-1
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
#include "scheme_helpers.h"
22

33
#include <ydb/core/base/path.h>
4+
#include <ydb/core/base/table_index.h>
45
#include <ydb/core/protos/external_sources.pb.h>
56

67
namespace NKikimr::NKqp::NSchemeHelpers {
@@ -46,7 +47,7 @@ bool SplitTablePath(const TString& tableName, const TString& database, std::pair
4647
}
4748

4849
TString CreateIndexTablePath(const TString& tableName, const TString& indexName) {
49-
return tableName + "/" + indexName + "/indexImplTable";
50+
return tableName + "/" + indexName + "/" + NTableIndex::ImplTable;
5051
}
5152

5253
bool SetDatabaseForLoginOperation(TString& result, bool getDomainLoginOnly, TMaybe<TString> domainName,

ydb/core/tx/schemeshard/schemeshard__operation_create_cdc_stream.cpp

+3-3
Original file line numberDiff line numberDiff line change
@@ -108,7 +108,7 @@ class TNewCdcStream: public TSubOperation {
108108
TString BuildWorkingDir() const {
109109
if (Transaction.GetCreateCdcStream().HasIndexName()) {
110110
return Transaction.GetWorkingDir() + "/"
111-
+ Transaction.GetCreateCdcStream().GetIndexName() + "/indexImplTable";
111+
+ Transaction.GetCreateCdcStream().GetIndexName() + "/" + NTableIndex::ImplTable;
112112
} else {
113113
return Transaction.GetWorkingDir();
114114
}
@@ -551,7 +551,7 @@ class TNewCdcStreamAtTable: public TSubOperation {
551551
}
552552
isIndexTable = true;
553553
workingDir += ("/" + tableName + "/" + op.GetIndexName());
554-
tableName = "indexImplTable";
554+
tableName = NTableIndex::ImplTable;
555555
}
556556

557557
LOG_N("TNewCdcStreamAtTable Propose"
@@ -1001,7 +1001,7 @@ TVector<ISubOperation::TPtr> CreateNewCdcStream(TOperationId opId, const TTxTran
10011001
continue;
10021002
}
10031003

1004-
const TPath indexImplPath = indexPath.Child("indexImplTable");
1004+
const TPath indexImplPath = indexPath.Child(NTableIndex::ImplTable);
10051005
if (!indexImplPath) {
10061006
return {CreateReject(opId, NKikimrScheme::StatusSchemeError,
10071007
"indexImplTable hasn't been found")};

ydb/core/tx/schemeshard/schemeshard_build_index__progress.cpp

+1-1
Original file line numberDiff line numberDiff line change
@@ -321,7 +321,7 @@ struct TSchemeShard::TIndexBuilder::TTxProgress: public TSchemeShard::TIndexBuil
321321
}
322322

323323
if (buildInfo->ImplTablePath.Empty() && buildInfo->IsBuildIndex()) {
324-
TPath implTable = TPath::Init(buildInfo->TablePathId, Self).Dive(buildInfo->IndexName).Dive("indexImplTable");
324+
TPath implTable = TPath::Init(buildInfo->TablePathId, Self).Dive(buildInfo->IndexName).Dive(NTableIndex::ImplTable);
325325
buildInfo->ImplTablePath = implTable.PathString();
326326

327327
TTableInfo::TPtr implTableInfo = Self->Tables.at(implTable.Base()->PathId);

0 commit comments

Comments
 (0)