Allow dst creator to create table with index #5779
Conversation
|
⚪
🟢
|
|
⚪
🟡
|
| TString Name; | ||
| TVector<TString> KeyColumns; | ||
| TVector<TColumn> Columns; | ||
| TVector<std::pair<TString, TVector<TString>>> SyncSecondaryIndexes; |
There was a problem hiding this comment.
Не нашел где это используется.
| { | ||
| auto desc = env.GetDescription(replicatedPath); | ||
| const auto& replicatedDesc = desc.GetPathDescription().GetTable(); | ||
|
|
||
| UNIT_ASSERT_VALUES_EQUAL(replicatedDesc.KeyColumnNamesSize(), tableDesc.KeyColumns.size()); | ||
| for (ui32 i = 0; i < replicatedDesc.KeyColumnNamesSize(); ++i) { | ||
| UNIT_ASSERT_VALUES_EQUAL(replicatedDesc.GetKeyColumnNames(i), tableDesc.KeyColumns[i]); | ||
| } | ||
|
|
||
| UNIT_ASSERT_VALUES_EQUAL(replicatedDesc.ColumnsSize(), tableDesc.Columns.size()); | ||
| for (ui32 i = 0; i < replicatedDesc.ColumnsSize(); ++i) { | ||
| auto pred = [name = replicatedDesc.GetColumns(i).GetName()](const auto& column) { | ||
| return name == column.Name; | ||
| }; | ||
|
|
||
| UNIT_ASSERT(FindIfPtr(tableDesc.Columns, pred)); | ||
| } | ||
|
|
||
| const auto& replCfg = replicatedDesc.GetReplicationConfig(); | ||
| UNIT_ASSERT_VALUES_EQUAL(replCfg.GetMode(), NKikimrSchemeOp::TTableReplicationConfig::REPLICATION_MODE_READ_ONLY); | ||
| UNIT_ASSERT_VALUES_EQUAL(replCfg.GetConsistency(), NKikimrSchemeOp::TTableReplicationConfig::CONSISTENCY_WEAK); | ||
| } |
There was a problem hiding this comment.
Это в другом тесте уже проверяется, можно не дублировать.
dcherednik
force-pushed
the
dst_creator_index_support
branch
from
f4b175f to
e3baa8b
Compare
CyberROFL
changed the title
|
⚪
🟡
*please be aware that the difference is based on comparing your commit and the last completed build from the post-commit, check comparation |
|
⚪
🟡
*please be aware that the difference is based on comparing your commit and the last completed build from the post-commit, check comparation |
2 participants
No description provided.