Skip to content

Commit 951e5fb

Browse files
MBkktMBkkt
committed
Rename tmp index impl tables to build index impl tables
1 parent d2299da commit 951e5fb

16 files changed

+84
-84
lines changed

‎ydb/core/base/table_index.cpp

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -154,9 +154,9 @@ bool IsImplTable(std::string_view tableName) {
154154
return Contains(ImplTables, tableName);
155155
}
156156

157-
bool IsTmpImplTable(std::string_view tableName) {
158-
// all impl tables that ends with "tmp" should be used only for index creation and dropped when index build is finished
159-
return tableName.ends_with("tmp");
157+
bool IsBuildImplTable(std::string_view tableName) {
158+
// all impl tables that ends with "build" should be used only for index creation and dropped when index build is finished
159+
return tableName.ends_with("build");
160160
}
161161

162162
}

‎ydb/core/base/table_index.h

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,6 @@ TTableColumns CalcTableImplDescription(NKikimrSchemeOp::EIndexType type, const T
2626

2727
TVector<TString> GetImplTables(NKikimrSchemeOp::EIndexType indexType);
2828
bool IsImplTable(std::string_view tableName);
29-
bool IsTmpImplTable(std::string_view tableName);
29+
bool IsBuildImplTable(std::string_view tableName);
3030

3131
}

‎ydb/core/base/table_vector_index.h

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@ inline constexpr const char* LevelTable_EmbeddingColumn = "__ydb_embedding";
1414
inline constexpr const char* PostingTable = "indexImplPostingTable";
1515
inline constexpr const char* PostingTable_ParentIdColumn = LevelTable_ParentIdColumn;
1616

17-
inline constexpr const char* TmpPostingTableSuffix0 = "0tmp";
18-
inline constexpr const char* TmpPostingTableSuffix1 = "1tmp";
17+
inline constexpr const char* BuildPostingTableSuffix0 = "0build";
18+
inline constexpr const char* BuildPostingTableSuffix1 = "1build";
1919

2020
}

‎ydb/core/protos/tx_datashard.proto

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1509,10 +1509,10 @@ message TEvLocalKMeansRequest {
15091509
UNSPECIFIED = 0;
15101510
SAMPLE = 1;
15111511
KMEANS = 2;
1512-
UPLOAD_MAIN_TO_TMP = 3;
1512+
UPLOAD_MAIN_TO_BUILD = 3;
15131513
UPLOAD_MAIN_TO_POSTING = 4;
1514-
UPLOAD_TMP_TO_TMP = 5;
1515-
UPLOAD_TMP_TO_POSTING = 6;
1514+
UPLOAD_BUILD_TO_BUILD = 5;
1515+
UPLOAD_BUILD_TO_POSTING = 6;
15161516
DONE = 7;
15171517
};
15181518
optional EState Upload = 11;

‎ydb/core/tx/datashard/datashard_ut_local_kmeans.cpp

Lines changed: 20 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -200,7 +200,7 @@ Y_UNIT_TEST_SUITE (TTxDataShardLocalKMeansScan) {
200200
CreateShardedTable(server, sender, "/Root", "table-posting", options);
201201
}
202202

203-
static void CreateTmpTable(Tests::TServer::TPtr server, TActorId sender, TShardedTableOptions options,
203+
static void CreateBuildTable(Tests::TServer::TPtr server, TActorId sender, TShardedTableOptions options,
204204
const char* name)
205205
{
206206
options.AllowSystemColumnNames(true);
@@ -402,7 +402,7 @@ Y_UNIT_TEST_SUITE (TTxDataShardLocalKMeansScan) {
402402
}
403403
}
404404

405-
Y_UNIT_TEST (MainToTmp) {
405+
Y_UNIT_TEST (MainToBuild) {
406406
TPortManager pm;
407407
TServerSettings serverSettings(pm.GetPort(2134));
408408
serverSettings.SetDomainName("Root");
@@ -434,7 +434,7 @@ Y_UNIT_TEST_SUITE (TTxDataShardLocalKMeansScan) {
434434

435435
auto create = [&] {
436436
CreateLevelTable(server, sender, options);
437-
CreateTmpTable(server, sender, options, "table-posting");
437+
CreateBuildTable(server, sender, options, "table-posting");
438438
};
439439
create();
440440
auto recreate = [&] {
@@ -449,7 +449,7 @@ Y_UNIT_TEST_SUITE (TTxDataShardLocalKMeansScan) {
449449
seed = 0;
450450
for (auto distance : {VectorIndexSettings::DISTANCE_MANHATTAN, VectorIndexSettings::DISTANCE_EUCLIDEAN}) {
451451
auto [level, posting] =
452-
DoLocalKMeans(server, sender, 0, seed, k, NKikimrTxDataShard::TEvLocalKMeansRequest::UPLOAD_MAIN_TO_TMP,
452+
DoLocalKMeans(server, sender, 0, seed, k, NKikimrTxDataShard::TEvLocalKMeansRequest::UPLOAD_MAIN_TO_BUILD,
453453
VectorIndexSettings::VECTOR_TYPE_UINT8, distance);
454454
UNIT_ASSERT_VALUES_EQUAL(level, "__ydb_parent = 0, __ydb_id = 1, __ydb_embedding = mm\3\n"
455455
"__ydb_parent = 0, __ydb_id = 2, __ydb_embedding = 11\3\n");
@@ -464,7 +464,7 @@ Y_UNIT_TEST_SUITE (TTxDataShardLocalKMeansScan) {
464464
seed = 111;
465465
for (auto distance : {VectorIndexSettings::DISTANCE_MANHATTAN, VectorIndexSettings::DISTANCE_EUCLIDEAN}) {
466466
auto [level, posting] =
467-
DoLocalKMeans(server, sender, 0, seed, k, NKikimrTxDataShard::TEvLocalKMeansRequest::UPLOAD_MAIN_TO_TMP,
467+
DoLocalKMeans(server, sender, 0, seed, k, NKikimrTxDataShard::TEvLocalKMeansRequest::UPLOAD_MAIN_TO_BUILD,
468468
VectorIndexSettings::VECTOR_TYPE_UINT8, distance);
469469
UNIT_ASSERT_VALUES_EQUAL(level, "__ydb_parent = 0, __ydb_id = 1, __ydb_embedding = 11\3\n"
470470
"__ydb_parent = 0, __ydb_id = 2, __ydb_embedding = mm\3\n");
@@ -479,7 +479,7 @@ Y_UNIT_TEST_SUITE (TTxDataShardLocalKMeansScan) {
479479
for (auto similarity :
480480
{VectorIndexSettings::SIMILARITY_INNER_PRODUCT, VectorIndexSettings::SIMILARITY_COSINE}) {
481481
auto [level, posting] =
482-
DoLocalKMeans(server, sender, 0, seed, k, NKikimrTxDataShard::TEvLocalKMeansRequest::UPLOAD_MAIN_TO_TMP,
482+
DoLocalKMeans(server, sender, 0, seed, k, NKikimrTxDataShard::TEvLocalKMeansRequest::UPLOAD_MAIN_TO_BUILD,
483483
VectorIndexSettings::VECTOR_TYPE_UINT8, similarity);
484484
UNIT_ASSERT_VALUES_EQUAL(level, "__ydb_parent = 0, __ydb_id = 1, __ydb_embedding = II\3\n");
485485
UNIT_ASSERT_VALUES_EQUAL(posting, "__ydb_parent = 1, key = 1, embedding = \x30\x30\3, data = one\n"
@@ -492,7 +492,7 @@ Y_UNIT_TEST_SUITE (TTxDataShardLocalKMeansScan) {
492492
seed = 13;
493493
{
494494
auto [level, posting] =
495-
DoLocalKMeans(server, sender, 0, seed, k, NKikimrTxDataShard::TEvLocalKMeansRequest::UPLOAD_MAIN_TO_TMP,
495+
DoLocalKMeans(server, sender, 0, seed, k, NKikimrTxDataShard::TEvLocalKMeansRequest::UPLOAD_MAIN_TO_BUILD,
496496
VectorIndexSettings::VECTOR_TYPE_UINT8, VectorIndexSettings::DISTANCE_COSINE);
497497
UNIT_ASSERT_VALUES_EQUAL(level, "__ydb_parent = 0, __ydb_id = 1, __ydb_embedding = II\3\n");
498498
UNIT_ASSERT_VALUES_EQUAL(posting, "__ydb_parent = 1, key = 1, embedding = \x30\x30\3, data = one\n"
@@ -504,7 +504,7 @@ Y_UNIT_TEST_SUITE (TTxDataShardLocalKMeansScan) {
504504
}
505505
}
506506

507-
Y_UNIT_TEST (TmpToPosting) {
507+
Y_UNIT_TEST (BuildToPosting) {
508508
TPortManager pm;
509509
TServerSettings serverSettings(pm.GetPort(2134));
510510
serverSettings.SetDomainName("Root");
@@ -521,7 +521,7 @@ Y_UNIT_TEST_SUITE (TTxDataShardLocalKMeansScan) {
521521
options.EnableOutOfOrder(true); // TODO(mbkkt) what is it?
522522
options.Shards(1);
523523

524-
CreateTmpTable(server, sender, options, "table-main");
524+
CreateBuildTable(server, sender, options, "table-main");
525525
// Upsert some initial values
526526
ExecSQL(server, sender,
527527
R"(
@@ -553,7 +553,7 @@ Y_UNIT_TEST_SUITE (TTxDataShardLocalKMeansScan) {
553553
seed = 0;
554554
for (auto distance : {VectorIndexSettings::DISTANCE_MANHATTAN, VectorIndexSettings::DISTANCE_EUCLIDEAN}) {
555555
auto [level, posting] = DoLocalKMeans(server, sender, 40, seed, k,
556-
NKikimrTxDataShard::TEvLocalKMeansRequest::UPLOAD_TMP_TO_POSTING,
556+
NKikimrTxDataShard::TEvLocalKMeansRequest::UPLOAD_BUILD_TO_POSTING,
557557
VectorIndexSettings::VECTOR_TYPE_UINT8, distance);
558558
UNIT_ASSERT_VALUES_EQUAL(level, "__ydb_parent = 40, __ydb_id = 41, __ydb_embedding = mm\3\n"
559559
"__ydb_parent = 40, __ydb_id = 42, __ydb_embedding = 11\3\n");
@@ -568,7 +568,7 @@ Y_UNIT_TEST_SUITE (TTxDataShardLocalKMeansScan) {
568568
seed = 111;
569569
for (auto distance : {VectorIndexSettings::DISTANCE_MANHATTAN, VectorIndexSettings::DISTANCE_EUCLIDEAN}) {
570570
auto [level, posting] = DoLocalKMeans(server, sender, 40, seed, k,
571-
NKikimrTxDataShard::TEvLocalKMeansRequest::UPLOAD_TMP_TO_POSTING,
571+
NKikimrTxDataShard::TEvLocalKMeansRequest::UPLOAD_BUILD_TO_POSTING,
572572
VectorIndexSettings::VECTOR_TYPE_UINT8, distance);
573573
UNIT_ASSERT_VALUES_EQUAL(level, "__ydb_parent = 40, __ydb_id = 41, __ydb_embedding = 11\3\n"
574574
"__ydb_parent = 40, __ydb_id = 42, __ydb_embedding = mm\3\n");
@@ -583,7 +583,7 @@ Y_UNIT_TEST_SUITE (TTxDataShardLocalKMeansScan) {
583583
for (auto similarity :
584584
{VectorIndexSettings::SIMILARITY_INNER_PRODUCT, VectorIndexSettings::SIMILARITY_COSINE}) {
585585
auto [level, posting] = DoLocalKMeans(server, sender, 40, seed, k,
586-
NKikimrTxDataShard::TEvLocalKMeansRequest::UPLOAD_TMP_TO_POSTING,
586+
NKikimrTxDataShard::TEvLocalKMeansRequest::UPLOAD_BUILD_TO_POSTING,
587587
VectorIndexSettings::VECTOR_TYPE_UINT8, similarity);
588588
UNIT_ASSERT_VALUES_EQUAL(level, "__ydb_parent = 40, __ydb_id = 41, __ydb_embedding = II\3\n");
589589
UNIT_ASSERT_VALUES_EQUAL(posting, "__ydb_parent = 41, key = 1, data = one\n"
@@ -596,7 +596,7 @@ Y_UNIT_TEST_SUITE (TTxDataShardLocalKMeansScan) {
596596
seed = 13;
597597
{
598598
auto [level, posting] = DoLocalKMeans(
599-
server, sender, 40, seed, k, NKikimrTxDataShard::TEvLocalKMeansRequest::UPLOAD_TMP_TO_POSTING,
599+
server, sender, 40, seed, k, NKikimrTxDataShard::TEvLocalKMeansRequest::UPLOAD_BUILD_TO_POSTING,
600600
VectorIndexSettings::VECTOR_TYPE_UINT8, VectorIndexSettings::DISTANCE_COSINE);
601601
UNIT_ASSERT_VALUES_EQUAL(level, "__ydb_parent = 40, __ydb_id = 41, __ydb_embedding = II\3\n");
602602
UNIT_ASSERT_VALUES_EQUAL(posting, "__ydb_parent = 41, key = 1, data = one\n"
@@ -608,7 +608,7 @@ Y_UNIT_TEST_SUITE (TTxDataShardLocalKMeansScan) {
608608
}
609609
}
610610

611-
Y_UNIT_TEST (TmpToTmp) {
611+
Y_UNIT_TEST (BuildToBuild) {
612612
TPortManager pm;
613613
TServerSettings serverSettings(pm.GetPort(2134));
614614
serverSettings.SetDomainName("Root");
@@ -625,7 +625,7 @@ Y_UNIT_TEST_SUITE (TTxDataShardLocalKMeansScan) {
625625
options.EnableOutOfOrder(true); // TODO(mbkkt) what is it?
626626
options.Shards(1);
627627

628-
CreateTmpTable(server, sender, options, "table-main");
628+
CreateBuildTable(server, sender, options, "table-main");
629629
// Upsert some initial values
630630
ExecSQL(server, sender,
631631
R"(
@@ -642,7 +642,7 @@ Y_UNIT_TEST_SUITE (TTxDataShardLocalKMeansScan) {
642642

643643
auto create = [&] {
644644
CreateLevelTable(server, sender, options);
645-
CreateTmpTable(server, sender, options, "table-posting");
645+
CreateBuildTable(server, sender, options, "table-posting");
646646
};
647647
create();
648648
auto recreate = [&] {
@@ -657,7 +657,7 @@ Y_UNIT_TEST_SUITE (TTxDataShardLocalKMeansScan) {
657657
seed = 0;
658658
for (auto distance : {VectorIndexSettings::DISTANCE_MANHATTAN, VectorIndexSettings::DISTANCE_EUCLIDEAN}) {
659659
auto [level, posting] =
660-
DoLocalKMeans(server, sender, 40, seed, k, NKikimrTxDataShard::TEvLocalKMeansRequest::UPLOAD_TMP_TO_TMP,
660+
DoLocalKMeans(server, sender, 40, seed, k, NKikimrTxDataShard::TEvLocalKMeansRequest::UPLOAD_BUILD_TO_BUILD,
661661
VectorIndexSettings::VECTOR_TYPE_UINT8, distance);
662662
UNIT_ASSERT_VALUES_EQUAL(level, "__ydb_parent = 40, __ydb_id = 41, __ydb_embedding = mm\3\n"
663663
"__ydb_parent = 40, __ydb_id = 42, __ydb_embedding = 11\3\n");
@@ -672,7 +672,7 @@ Y_UNIT_TEST_SUITE (TTxDataShardLocalKMeansScan) {
672672
seed = 111;
673673
for (auto distance : {VectorIndexSettings::DISTANCE_MANHATTAN, VectorIndexSettings::DISTANCE_EUCLIDEAN}) {
674674
auto [level, posting] =
675-
DoLocalKMeans(server, sender, 40, seed, k, NKikimrTxDataShard::TEvLocalKMeansRequest::UPLOAD_TMP_TO_TMP,
675+
DoLocalKMeans(server, sender, 40, seed, k, NKikimrTxDataShard::TEvLocalKMeansRequest::UPLOAD_BUILD_TO_BUILD,
676676
VectorIndexSettings::VECTOR_TYPE_UINT8, distance);
677677
UNIT_ASSERT_VALUES_EQUAL(level, "__ydb_parent = 40, __ydb_id = 41, __ydb_embedding = 11\3\n"
678678
"__ydb_parent = 40, __ydb_id = 42, __ydb_embedding = mm\3\n");
@@ -687,7 +687,7 @@ Y_UNIT_TEST_SUITE (TTxDataShardLocalKMeansScan) {
687687
for (auto similarity :
688688
{VectorIndexSettings::SIMILARITY_INNER_PRODUCT, VectorIndexSettings::SIMILARITY_COSINE}) {
689689
auto [level, posting] =
690-
DoLocalKMeans(server, sender, 40, seed, k, NKikimrTxDataShard::TEvLocalKMeansRequest::UPLOAD_TMP_TO_TMP,
690+
DoLocalKMeans(server, sender, 40, seed, k, NKikimrTxDataShard::TEvLocalKMeansRequest::UPLOAD_BUILD_TO_BUILD,
691691
VectorIndexSettings::VECTOR_TYPE_UINT8, similarity);
692692
UNIT_ASSERT_VALUES_EQUAL(level, "__ydb_parent = 40, __ydb_id = 41, __ydb_embedding = II\3\n");
693693
UNIT_ASSERT_VALUES_EQUAL(posting, "__ydb_parent = 41, key = 1, embedding = \x30\x30\3, data = one\n"
@@ -700,7 +700,7 @@ Y_UNIT_TEST_SUITE (TTxDataShardLocalKMeansScan) {
700700
seed = 13;
701701
{
702702
auto [level, posting] =
703-
DoLocalKMeans(server, sender, 40, seed, k, NKikimrTxDataShard::TEvLocalKMeansRequest::UPLOAD_TMP_TO_TMP,
703+
DoLocalKMeans(server, sender, 40, seed, k, NKikimrTxDataShard::TEvLocalKMeansRequest::UPLOAD_BUILD_TO_BUILD,
704704
VectorIndexSettings::VECTOR_TYPE_UINT8, VectorIndexSettings::DISTANCE_COSINE);
705705
UNIT_ASSERT_VALUES_EQUAL(level, "__ydb_parent = 40, __ydb_id = 41, __ydb_embedding = II\3\n");
706706
UNIT_ASSERT_VALUES_EQUAL(posting, "__ydb_parent = 41, key = 1, embedding = \x30\x30\3, data = one\n"

‎ydb/core/tx/datashard/kmeans_helper.cpp

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@ NTable::TLead CreateLeadFrom(const TTableRange& range) {
2727
return lead;
2828
}
2929

30-
void AddRowMain2Tmp(TBufferData& buffer, ui32 parent, TArrayRef<const TCell> key, const NTable::TRowState& row) {
30+
void AddRowMain2Build(TBufferData& buffer, ui32 parent, TArrayRef<const TCell> key, const NTable::TRowState& row) {
3131
std::array<TCell, 1> cells;
3232
cells[0] = TCell::Make(parent);
3333
auto pk = TSerializedCellVec::Serialize(cells);
@@ -46,15 +46,15 @@ void AddRowMain2Posting(TBufferData& buffer, ui32 parent, TArrayRef<const TCell>
4646
TSerializedCellVec::Serialize((*row).Slice(dataPos)));
4747
}
4848

49-
void AddRowTmp2Tmp(TBufferData& buffer, ui32 parent, TArrayRef<const TCell> key, const NTable::TRowState& row) {
49+
void AddRowBuild2Build(TBufferData& buffer, ui32 parent, TArrayRef<const TCell> key, const NTable::TRowState& row) {
5050
std::array<TCell, 1> cells;
5151
cells[0] = TCell::Make(parent);
5252
auto pk = TSerializedCellVec::Serialize(cells);
5353
TSerializedCellVec::UnsafeAppendCells(key.Slice(1), pk);
5454
buffer.AddRow(TSerializedCellVec{key}, TSerializedCellVec{std::move(pk)}, TSerializedCellVec::Serialize(*row));
5555
}
5656

57-
void AddRowTmp2Posting(TBufferData& buffer, ui32 parent, TArrayRef<const TCell> key, const NTable::TRowState& row,
57+
void AddRowBuild2Posting(TBufferData& buffer, ui32 parent, TArrayRef<const TCell> key, const NTable::TRowState& row,
5858
ui32 dataPos)
5959
{
6060
std::array<TCell, 1> cells;
@@ -109,12 +109,12 @@ MakeUploadTypes(const TUserTable& table, NKikimrTxDataShard::TEvLocalKMeansReque
109109
addType(table.Columns.at(column).Name);
110110
}
111111
switch (uploadState) {
112-
case NKikimrTxDataShard::TEvLocalKMeansRequest::UPLOAD_MAIN_TO_TMP:
113-
case NKikimrTxDataShard::TEvLocalKMeansRequest::UPLOAD_TMP_TO_TMP:
112+
case NKikimrTxDataShard::TEvLocalKMeansRequest::UPLOAD_MAIN_TO_BUILD:
113+
case NKikimrTxDataShard::TEvLocalKMeansRequest::UPLOAD_BUILD_TO_BUILD:
114114
addType(embedding);
115115
[[fallthrough]];
116116
case NKikimrTxDataShard::TEvLocalKMeansRequest::UPLOAD_MAIN_TO_POSTING:
117-
case NKikimrTxDataShard::TEvLocalKMeansRequest::UPLOAD_TMP_TO_POSTING: {
117+
case NKikimrTxDataShard::TEvLocalKMeansRequest::UPLOAD_BUILD_TO_POSTING: {
118118
for (const auto& column : data) {
119119
addType(column);
120120
}

‎ydb/core/tx/datashard/kmeans_helper.h

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -187,14 +187,14 @@ ui32 FeedEmbedding(const TCalculation<TMetric>& calculation, std::span<const TSt
187187
return calculation.FindClosest(clusters, embedding.data());
188188
}
189189

190-
void AddRowMain2Tmp(TBufferData& buffer, ui32 parent, TArrayRef<const TCell> key, const NTable::TRowState& row);
190+
void AddRowMain2Build(TBufferData& buffer, ui32 parent, TArrayRef<const TCell> key, const NTable::TRowState& row);
191191

192192
void AddRowMain2Posting(TBufferData& buffer, ui32 parent, TArrayRef<const TCell> key, const NTable::TRowState& row,
193193
ui32 dataPos);
194194

195-
void AddRowTmp2Tmp(TBufferData& buffer, ui32 parent, TArrayRef<const TCell> key, const NTable::TRowState& row);
195+
void AddRowBuild2Build(TBufferData& buffer, ui32 parent, TArrayRef<const TCell> key, const NTable::TRowState& row);
196196

197-
void AddRowTmp2Posting(TBufferData& buffer, ui32 parent, TArrayRef<const TCell> key, const NTable::TRowState& row,
197+
void AddRowBuild2Posting(TBufferData& buffer, ui32 parent, TArrayRef<const TCell> key, const NTable::TRowState& row,
198198
ui32 dataPos);
199199

200200
TTags MakeUploadTags(const TUserTable& table, const TProtoStringType& embedding,

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -94,7 +94,7 @@ TVector<ISubOperation::TPtr> ApplyBuildIndex(TOperationId nextId, const TTxTrans
9494
for (auto& indexChildItems : index.Base()->GetChildren()) {
9595
const auto& indexImplTableName = indexChildItems.first;
9696
const auto partId = NextPartId(nextId, result);
97-
if (NTableIndex::IsTmpImplTable(indexImplTableName)) {
97+
if (NTableIndex::IsBuildImplTable(indexImplTableName)) {
9898
bool rejected = false;
9999
auto op = DropIndexImplTable(index, nextId, partId, indexImplTableName, indexChildItems.second, rejected);
100100
if (rejected) {

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -134,8 +134,8 @@ TVector<ISubOperation::TPtr> CreateBuildIndex(TOperationId opId, const TTxTransa
134134
result.push_back(createImplTable(CalcVectorKmeansTreePostingImplTableDesc(tableInfo, tableInfo->PartitionConfig(), implTableColumns, indexPostingTableDesc)));
135135
// TODO Maybe better to use partition from main table
136136
// This tables are temporary and handled differently in apply_build_index
137-
result.push_back(createImplTable(CalcVectorKmeansTreePostingImplTableDesc(tableInfo, tableInfo->PartitionConfig(), implTableColumns, indexPostingTableDesc, NTableVectorKmeansTreeIndex::TmpPostingTableSuffix0)));
138-
result.push_back(createImplTable(CalcVectorKmeansTreePostingImplTableDesc(tableInfo, tableInfo->PartitionConfig(), implTableColumns, indexPostingTableDesc, NTableVectorKmeansTreeIndex::TmpPostingTableSuffix1)));
137+
result.push_back(createImplTable(CalcVectorKmeansTreePostingImplTableDesc(tableInfo, tableInfo->PartitionConfig(), implTableColumns, indexPostingTableDesc, NTableVectorKmeansTreeIndex::BuildPostingTableSuffix0)));
138+
result.push_back(createImplTable(CalcVectorKmeansTreePostingImplTableDesc(tableInfo, tableInfo->PartitionConfig(), implTableColumns, indexPostingTableDesc, NTableVectorKmeansTreeIndex::BuildPostingTableSuffix1)));
139139
} else {
140140
NKikimrSchemeOp::TTableDescription indexTableDesc;
141141
// TODO After IndexImplTableDescriptions are persisted, this should be replaced with Y_ABORT_UNLESS

0 commit comments

Comments
 (0)