Skip to content

Commit 3a4b1a7

Browse files
azevaykinazevaykin
authored
Forgotten OwnerId in EvWrite (#945)
1 parent 4c467b3 commit 3a4b1a7

10 files changed

+43
-38
lines changed

‎ydb/core/tx/columnshard/ut_rw/ut_columnshard_read_write.cpp

+9-3
Original file line numberDiff line numberDiff line change
@@ -1564,7 +1564,9 @@ Y_UNIT_TEST_SUITE(EvWrite) {
15641564
TTestBasicRuntime runtime;
15651565
TTester::Setup(runtime);
15661566

1567+
const ui64 ownerId = 0;
15671568
const ui64 tableId = 1;
1569+
const ui64 schemaVersion = 1;
15681570
const std::vector<std::pair<TString, TTypeInfo>> schema = {
15691571
{"key", TTypeInfo(NTypeIds::Uint64) },
15701572
{"field", TTypeInfo(NTypeIds::Utf8) }
@@ -1583,7 +1585,7 @@ Y_UNIT_TEST_SUITE(EvWrite) {
15831585

15841586
auto evWrite = std::make_unique<NKikimr::NEvents::TDataEvents::TEvWrite>(txId, NKikimrDataEvents::TEvWrite::MODE_PREPARE);
15851587
ui64 payloadIndex = NEvWrite::TPayloadHelper<NKikimr::NEvents::TDataEvents::TEvWrite>(*evWrite).AddDataToPayload(std::move(blobData));
1586-
evWrite->AddOperation(NKikimrDataEvents::TEvWrite::TOperation::OPERATION_REPLACE, tableId, 1, columnsIds, payloadIndex, NKikimrDataEvents::FORMAT_ARROW);
1588+
evWrite->AddOperation(NKikimrDataEvents::TEvWrite::TOperation::OPERATION_REPLACE, {ownerId, tableId, schemaVersion}, columnsIds, payloadIndex, NKikimrDataEvents::FORMAT_ARROW);
15871589

15881590
TActorId sender = runtime.AllocateEdgeActor();
15891591
ForwardToTablet(runtime, TTestTxConfig::TxTablet0, sender, evWrite.release());
@@ -1612,7 +1614,9 @@ Y_UNIT_TEST_SUITE(EvWrite) {
16121614
TTestBasicRuntime runtime;
16131615
TTester::Setup(runtime);
16141616

1617+
const ui64 ownerId = 0;
16151618
const ui64 tableId = 1;
1619+
const ui64 schemaVersion = 1;
16161620
const std::vector<std::pair<TString, TTypeInfo>> schema = {
16171621
{"key", TTypeInfo(NTypeIds::Uint64) },
16181622
{"field", TTypeInfo(NTypeIds::Utf8) }
@@ -1631,7 +1635,7 @@ Y_UNIT_TEST_SUITE(EvWrite) {
16311635

16321636
auto evWrite = std::make_unique<NKikimr::NEvents::TDataEvents::TEvWrite>(txId, NKikimrDataEvents::TEvWrite::MODE_PREPARE);
16331637
ui64 payloadIndex = NEvWrite::TPayloadHelper<NKikimr::NEvents::TDataEvents::TEvWrite>(*evWrite).AddDataToPayload(std::move(blobData));
1634-
evWrite->AddOperation(NKikimrDataEvents::TEvWrite::TOperation::OPERATION_REPLACE, tableId, 1, columnsIds, payloadIndex, NKikimrDataEvents::FORMAT_ARROW);
1638+
evWrite->AddOperation(NKikimrDataEvents::TEvWrite::TOperation::OPERATION_REPLACE, {ownerId, tableId, schemaVersion}, columnsIds, payloadIndex, NKikimrDataEvents::FORMAT_ARROW);
16351639

16361640
TActorId sender = runtime.AllocateEdgeActor();
16371641
ForwardToTablet(runtime, TTestTxConfig::TxTablet0, sender, evWrite.release());
@@ -1657,7 +1661,9 @@ Y_UNIT_TEST_SUITE(EvWrite) {
16571661
TTestBasicRuntime runtime;
16581662
TTester::Setup(runtime);
16591663

1664+
const ui64 ownerId = 0;
16601665
const ui64 tableId = 1;
1666+
const ui64 schemaVersion = 1;
16611667
const std::vector<std::pair<TString, TTypeInfo>> schema = {
16621668
{"key", TTypeInfo(NTypeIds::Uint64) },
16631669
{"field", TTypeInfo(NTypeIds::Utf8) }
@@ -1676,7 +1682,7 @@ Y_UNIT_TEST_SUITE(EvWrite) {
16761682

16771683
auto evWrite = std::make_unique<NKikimr::NEvents::TDataEvents::TEvWrite>(txId, NKikimrDataEvents::TEvWrite::MODE_PREPARE);
16781684
ui64 payloadIndex = NEvWrite::TPayloadHelper<NKikimr::NEvents::TDataEvents::TEvWrite>(*evWrite).AddDataToPayload(std::move(blobData));
1679-
evWrite->AddOperation(NKikimrDataEvents::TEvWrite::TOperation::OPERATION_REPLACE, tableId, 1, columnsIds, payloadIndex, NKikimrDataEvents::FORMAT_ARROW);
1685+
evWrite->AddOperation(NKikimrDataEvents::TEvWrite::TOperation::OPERATION_REPLACE, {ownerId, tableId, schemaVersion}, columnsIds, payloadIndex, NKikimrDataEvents::FORMAT_ARROW);
16801686

16811687
TActorId sender = runtime.AllocateEdgeActor();
16821688
ForwardToTablet(runtime, TTestTxConfig::TxTablet0, sender, evWrite.release());

‎ydb/core/tx/columnshard/ut_rw/ut_normalizer.cpp

+3-1
Original file line numberDiff line numberDiff line change
@@ -225,7 +225,9 @@ Y_UNIT_TEST_SUITE(Normalizers) {
225225
TTestBasicRuntime runtime;
226226
TTester::Setup(runtime);
227227

228+
const ui64 ownerId = 0;
228229
const ui64 tableId = 1;
230+
const ui64 schemaVersion = 1;
229231
const std::vector<std::pair<TString, TTypeInfo>> schema = {
230232
{"key1", TTypeInfo(NTypeIds::Uint64) },
231233
{"key2", TTypeInfo(NTypeIds::Uint64) },
@@ -245,7 +247,7 @@ Y_UNIT_TEST_SUITE(Normalizers) {
245247

246248
auto evWrite = std::make_unique<NKikimr::NEvents::TDataEvents::TEvWrite>(txId, NKikimrDataEvents::TEvWrite::MODE_PREPARE);
247249
ui64 payloadIndex = NEvWrite::TPayloadHelper<NKikimr::NEvents::TDataEvents::TEvWrite>(*evWrite).AddDataToPayload(std::move(blobData));
248-
evWrite->AddOperation(NKikimrDataEvents::TEvWrite::TOperation::OPERATION_REPLACE, tableId, 1, columnsIds, payloadIndex, NKikimrDataEvents::FORMAT_ARROW);
250+
evWrite->AddOperation(NKikimrDataEvents::TEvWrite::TOperation::OPERATION_REPLACE, {ownerId, tableId, schemaVersion}, columnsIds, payloadIndex, NKikimrDataEvents::FORMAT_ARROW);
249251

250252
TActorId sender = runtime.AllocateEdgeActor();
251253
ForwardToTablet(runtime, TTestTxConfig::TxTablet0, sender, evWrite.release());

‎ydb/core/tx/data_events/events.h

+5-4
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@
22

33
#include <library/cpp/lwtrace/shuttle.h>
44

5+
#include <ydb/core/scheme/scheme_tabledefs.h>
56
#include <ydb/core/protos/data_events.pb.h>
67
#include <ydb/core/base/events.h>
78

@@ -44,8 +45,7 @@ struct TDataEvents {
4445
Record.SetTxMode(txMode);
4546
}
4647

47-
void AddOperation(NKikimrDataEvents::TEvWrite_TOperation::EOperationType operationType, ui64 tableId,
48-
ui64 schemaVersion, const std::vector<ui32>& columnIds,
48+
void AddOperation(NKikimrDataEvents::TEvWrite_TOperation::EOperationType operationType, const TTableId& tableId, const std::vector<ui32>& columnIds,
4949
ui64 payloadIndex, NKikimrDataEvents::EDataFormat payloadFormat) {
5050
Y_ABORT_UNLESS(operationType != NKikimrDataEvents::TEvWrite::TOperation::OPERATION_UNSPECIFIED);
5151
Y_ABORT_UNLESS(payloadFormat != NKikimrDataEvents::FORMAT_UNSPECIFIED);
@@ -54,8 +54,9 @@ struct TDataEvents {
5454
operation->SetType(operationType);
5555
operation->SetPayloadFormat(payloadFormat);
5656
operation->SetPayloadIndex(payloadIndex);
57-
operation->MutableTableId()->SetTableId(tableId);
58-
operation->MutableTableId()->SetSchemaVersion(schemaVersion);
57+
operation->MutableTableId()->SetOwnerId(tableId.PathId.OwnerId);
58+
operation->MutableTableId()->SetTableId(tableId.PathId.LocalPathId);
59+
operation->MutableTableId()->SetSchemaVersion(tableId.SchemaVersion);
5960
operation->MutableColumnIds()->Assign(columnIds.begin(), columnIds.end());
6061
}
6162

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

+7-12
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,7 @@ TVector<TShardedTableOptions::TColumn> GetMoviesColumns() {
4747
return columns;
4848
}
4949

50-
std::tuple<TVector<ui64>, ui64> CreateTable(Tests::TServer::TPtr server,
50+
std::tuple<TVector<ui64>, TTableId> CreateTable(Tests::TServer::TPtr server,
5151
TActorId sender,
5252
const TString &root,
5353
const TString &name,
@@ -64,7 +64,7 @@ std::tuple<TVector<ui64>, ui64> CreateTable(Tests::TServer::TPtr server,
6464
return CreateShardedTable(server, sender, root, name, opts);
6565
}
6666

67-
std::tuple<TVector<ui64>, ui64> CreateMoviesTable(Tests::TServer::TPtr server,
67+
std::tuple<TVector<ui64>, TTableId> CreateMoviesTable(Tests::TServer::TPtr server,
6868
TActorId sender,
6969
const TString &root,
7070
const TString &name)
@@ -317,9 +317,8 @@ void AddRangeQuery(
317317
struct TTableInfo {
318318
TString Name;
319319

320-
ui64 TableId;
320+
TTableId TableId;
321321
ui64 TabletId;
322-
ui64 OwnerId;
323322
NKikimrTxDataShard::TEvGetInfoResponse::TUserTable UserTable;
324323

325324
TActorId ClientId;
@@ -376,7 +375,6 @@ struct TTestHelper {
376375
table1.TabletId = shards.at(0);
377376

378377
auto [tables, ownerId] = GetTables(Server, table1.TabletId);
379-
table1.OwnerId = ownerId;
380378
table1.UserTable = tables["table-1"];
381379

382380
table1.ClientId = runtime.ConnectToPipe(table1.TabletId, Sender, 0, GetTestPipeConfig());
@@ -401,7 +399,6 @@ struct TTestHelper {
401399
table2.TabletId = shards.at(0);
402400

403401
auto [tables, ownerId] = GetTables(Server, table2.TabletId);
404-
table2.OwnerId = ownerId;
405402
table2.UserTable = tables["movies"];
406403

407404
table2.ClientId = runtime.ConnectToPipe(table2.TabletId, Sender, 0, GetTestPipeConfig());
@@ -418,7 +415,6 @@ struct TTestHelper {
418415
table3.TabletId = shards.at(0);
419416

420417
auto [tables, ownerId] = GetTables(Server, table3.TabletId);
421-
table3.OwnerId = ownerId;
422418
table3.UserTable = tables["table-1-many"];
423419

424420
table3.ClientId = runtime.ConnectToPipe(table3.TabletId, Sender, 0, GetTestPipeConfig());
@@ -508,7 +504,7 @@ struct TTestHelper {
508504
auto& record = request->Record;
509505

510506
record.SetReadId(readId);
511-
record.MutableTableId()->SetOwnerId(table.OwnerId);
507+
record.MutableTableId()->SetOwnerId(table.TableId.PathId.OwnerId);
512508
record.MutableTableId()->SetTableId(table.UserTable.GetPathId());
513509

514510
const auto& description = table.UserTable.GetDescription();
@@ -764,7 +760,7 @@ struct TTestHelper {
764760

765761
auto evWrite = std::make_unique<NKikimr::NEvents::TDataEvents::TEvWrite>(txId, txMode);
766762
ui64 payloadIndex = NKikimr::NEvWrite::TPayloadHelper<NKikimr::NEvents::TDataEvents::TEvWrite>(*evWrite).AddDataToPayload(matrix.ReleaseBuffer());
767-
evWrite->AddOperation(NKikimrDataEvents::TEvWrite::TOperation::OPERATION_UPSERT, table.TableId, 1, columnIds, payloadIndex, NKikimrDataEvents::FORMAT_CELLVEC);
763+
evWrite->AddOperation(NKikimrDataEvents::TEvWrite::TOperation::OPERATION_UPSERT, table.TableId, columnIds, payloadIndex, NKikimrDataEvents::FORMAT_CELLVEC);
768764

769765
return Write(*Server->GetRuntime(), Sender, table.TabletId, std::move(evWrite));
770766
}
@@ -3618,13 +3614,12 @@ Y_UNIT_TEST_SUITE(DataShardReadIteratorPageFaults) {
36183614
.Columns({
36193615
{"key", "Uint32", true, false},
36203616
{"value", "Uint32", false, false}});
3621-
CreateShardedTable(server, sender, "/Root", "table-1", opts);
3617+
auto [shards, tableId1] = CreateShardedTable(server, sender, "/Root", "table-1", opts);
36223618

36233619
ExecSQL(server, sender, Q_("UPSERT INTO `/Root/table-1` (key, value) VALUES (1, 1), (2, 2), (3, 3), (4, 4), (5, 5), (6, 6)"));
36243620
SimulateSleep(runtime, TDuration::Seconds(1));
36253621

3626-
const auto shard1 = GetTableShards(server, sender, "/Root/table-1").at(0);
3627-
const auto tableId1 = ResolveTableId(server, sender, "/Root/table-1");
3622+
const auto shard1 = shards.at(0);
36283623
CompactTable(runtime, shard1, tableId1, false);
36293624
RebootTablet(runtime, shard1, sender);
36303625
SimulateSleep(runtime, TDuration::Seconds(1));

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

+3-4
Original file line numberDiff line numberDiff line change
@@ -79,9 +79,8 @@ Y_UNIT_TEST_SUITE(DataShardStats) {
7979

8080
InitRoot(server, sender);
8181

82-
CreateShardedTable(server, sender, "/Root", "table-1", 1);
83-
const auto shard1 = GetTableShards(server, sender, "/Root/table-1").at(0);
84-
const auto tableId1 = ResolveTableId(server, sender, "/Root/table-1");
82+
auto [shards, tableId1] = CreateShardedTable(server, sender, "/Root", "table-1", 1);
83+
ui64 shard1 = shards.at(0);
8584

8685
ExecSQL(server, sender, "UPSERT INTO `/Root/table-1` (key, value) VALUES (1, 1), (2, 2), (3, 3)");
8786

@@ -113,7 +112,7 @@ Y_UNIT_TEST_SUITE(DataShardStats) {
113112
UNIT_ASSERT_VALUES_EQUAL(stats.GetTableStats().GetChannels()[0].GetIndexSize(), 54u);
114113
}
115114

116-
Write(runtime, sender, shard1, tableId1.PathId.LocalPathId, TShardedTableOptions().Columns_, 1, 100, NKikimrDataEvents::TEvWrite::MODE_IMMEDIATE);
115+
Write(runtime, sender, shard1, tableId1, TShardedTableOptions().Columns_, 1, 100, NKikimrDataEvents::TEvWrite::MODE_IMMEDIATE);
117116

118117
{
119118
Cerr << "... waiting for stats after write" << Endl;

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

+1-1
Original file line numberDiff line numberDiff line change
@@ -75,7 +75,7 @@ Y_UNIT_TEST_SUITE(DataShardWrite) {
7575

7676
auto evWrite = std::make_unique<NKikimr::NEvents::TDataEvents::TEvWrite>(100, NKikimrDataEvents::TEvWrite::MODE_IMMEDIATE);
7777
ui64 payloadIndex = NKikimr::NEvWrite::TPayloadHelper<NKikimr::NEvents::TDataEvents::TEvWrite>(*evWrite).AddDataToPayload(matrix.ReleaseBuffer());
78-
evWrite->AddOperation(NKikimrDataEvents::TEvWrite::TOperation::OPERATION_UPSERT, tableId, 1, {1}, payloadIndex, NKikimrDataEvents::FORMAT_CELLVEC);
78+
evWrite->AddOperation(NKikimrDataEvents::TEvWrite::TOperation::OPERATION_UPSERT, tableId, {1}, payloadIndex, NKikimrDataEvents::FORMAT_CELLVEC);
7979

8080
const auto& record = Write(runtime, sender, shards[0], std::move(evWrite), NKikimrDataEvents::TEvWriteResult::STATUS_BAD_REQUEST);
8181

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

+1-1
Original file line numberDiff line numberDiff line change
@@ -159,7 +159,7 @@ bool TValidatedWriteTx::ParseRecord(const TDataShard::TTableInfos& tableInfos) {
159159
}
160160
}
161161

162-
TableId = TTableId(tableIdRecord.ownerid(), tableIdRecord.GetTableId(), tableIdRecord.GetSchemaVersion());
162+
TableId = TTableId(tableIdRecord.GetOwnerId(), tableIdRecord.GetTableId(), tableIdRecord.GetSchemaVersion());
163163
return true;
164164
}
165165

‎ydb/core/tx/datashard/ut_common/datashard_ut_common.cpp

+6-6
Original file line numberDiff line numberDiff line change
@@ -1103,7 +1103,7 @@ static ui64 RunSchemeTx(
11031103
return ev->Get()->Record.GetTxId();
11041104
}
11051105

1106-
std::tuple<TVector<ui64>, ui64> CreateShardedTable(
1106+
std::tuple<TVector<ui64>, TTableId> CreateShardedTable(
11071107
Tests::TServer::TPtr server,
11081108
TActorId sender,
11091109
const TString &root,
@@ -1224,12 +1224,12 @@ std::tuple<TVector<ui64>, ui64> CreateShardedTable(
12241224

12251225
TString path = TStringBuilder() << root << "/" << name;
12261226
const auto& shards = GetTableShards(server, sender, path);
1227-
const ui64 tableId = ResolveTableId(server, sender, path).PathId.LocalPathId;
1227+
TTableId tableId = ResolveTableId(server, sender, path);
12281228

12291229
return {shards, tableId};
12301230
}
12311231

1232-
std::tuple<TVector<ui64>, ui64> CreateShardedTable(
1232+
std::tuple<TVector<ui64>, TTableId> CreateShardedTable(
12331233
Tests::TServer::TPtr server,
12341234
TActorId sender,
12351235
const TString &root,
@@ -1805,7 +1805,7 @@ void ExecSQL(Tests::TServer::TPtr server,
18051805
UNIT_ASSERT_VALUES_EQUAL(ev->Get()->Record.GetRef().GetYdbStatus(), code);
18061806
}
18071807

1808-
std::unique_ptr<NEvents::TDataEvents::TEvWrite> MakeWriteRequest(ui64 txId, NKikimrDataEvents::TEvWrite::ETxMode txMode, ui64 tableId, const TVector<TShardedTableOptions::TColumn>& columns, ui32 rowCount) {
1808+
std::unique_ptr<NEvents::TDataEvents::TEvWrite> MakeWriteRequest(ui64 txId, NKikimrDataEvents::TEvWrite::ETxMode txMode, const TTableId& tableId, const TVector<TShardedTableOptions::TColumn>& columns, ui32 rowCount) {
18091809
std::vector<ui32> columnIds(columns.size());
18101810
std::iota(columnIds.begin(), columnIds.end(), 1);
18111811

@@ -1836,7 +1836,7 @@ std::unique_ptr<NEvents::TDataEvents::TEvWrite> MakeWriteRequest(ui64 txId, NKik
18361836

18371837
auto evWrite = std::make_unique<NKikimr::NEvents::TDataEvents::TEvWrite>(txId, txMode);
18381838
ui64 payloadIndex = NKikimr::NEvWrite::TPayloadHelper<NKikimr::NEvents::TDataEvents::TEvWrite>(*evWrite).AddDataToPayload(std::move(blobData));
1839-
evWrite->AddOperation(NKikimrDataEvents::TEvWrite::TOperation::OPERATION_UPSERT, tableId, 1, columnIds, payloadIndex, NKikimrDataEvents::FORMAT_CELLVEC);
1839+
evWrite->AddOperation(NKikimrDataEvents::TEvWrite::TOperation::OPERATION_UPSERT, tableId, columnIds, payloadIndex, NKikimrDataEvents::FORMAT_CELLVEC);
18401840

18411841
return evWrite;
18421842
}
@@ -1869,7 +1869,7 @@ NKikimrDataEvents::TEvWriteResult Write(TTestActorRuntime& runtime, TActorId sen
18691869
return resultRecord;
18701870
}
18711871

1872-
NKikimrDataEvents::TEvWriteResult Write(TTestActorRuntime& runtime, TActorId sender, ui64 shardId, ui64 tableId, const TVector<TShardedTableOptions::TColumn>& columns, ui32 rowCount, ui64 txId, NKikimrDataEvents::TEvWrite::ETxMode txMode, NKikimrDataEvents::TEvWriteResult::EStatus expectedStatus, NWilson::TTraceId traceId)
1872+
NKikimrDataEvents::TEvWriteResult Write(TTestActorRuntime& runtime, TActorId sender, ui64 shardId, const TTableId& tableId, const TVector<TShardedTableOptions::TColumn>& columns, ui32 rowCount, ui64 txId, NKikimrDataEvents::TEvWrite::ETxMode txMode, NKikimrDataEvents::TEvWriteResult::EStatus expectedStatus, NWilson::TTraceId traceId)
18731873
{
18741874
auto request = MakeWriteRequest(txId, txMode, tableId, columns, rowCount);
18751875
return Write(runtime, sender, shardId, std::move(request), expectedStatus, std::move(traceId));

‎ydb/core/tx/datashard/ut_common/datashard_ut_common.h

+3-3
Original file line numberDiff line numberDiff line change
@@ -501,14 +501,14 @@ struct TShardedTableOptions {
501501
void N(NUnitTest::TTestContext&)
502502

503503
// Create table, returns shards & tableId
504-
std::tuple<TVector<ui64>, ui64> CreateShardedTable(Tests::TServer::TPtr server,
504+
std::tuple<TVector<ui64>, TTableId> CreateShardedTable(Tests::TServer::TPtr server,
505505
TActorId sender,
506506
const TString &root,
507507
const TString &name,
508508
const TShardedTableOptions &opts = TShardedTableOptions());
509509

510510
// Create table, returns shards & tableId
511-
std::tuple<TVector<ui64>, ui64> CreateShardedTable(Tests::TServer::TPtr server,
511+
std::tuple<TVector<ui64>, TTableId> CreateShardedTable(Tests::TServer::TPtr server,
512512
TActorId sender,
513513
const TString &root,
514514
const TString &name,
@@ -711,7 +711,7 @@ void ExecSQL(Tests::TServer::TPtr server,
711711
Ydb::StatusIds::StatusCode code = Ydb::StatusIds::SUCCESS);
712712

713713
NKikimrDataEvents::TEvWriteResult Write(TTestActorRuntime& runtime, TActorId sender, ui64 shardId, std::unique_ptr<NEvents::TDataEvents::TEvWrite>&& request, NKikimrDataEvents::TEvWriteResult::EStatus expectedStatus = NKikimrDataEvents::TEvWriteResult::STATUS_UNSPECIFIED, NWilson::TTraceId traceId = {});
714-
NKikimrDataEvents::TEvWriteResult Write(TTestActorRuntime& runtime, TActorId sender, ui64 shardId, ui64 tableId, const TVector<TShardedTableOptions::TColumn>& columns, ui32 rowCount, ui64 txId, NKikimrDataEvents::TEvWrite::ETxMode txMode, NKikimrDataEvents::TEvWriteResult::EStatus expectedStatus = NKikimrDataEvents::TEvWriteResult::STATUS_UNSPECIFIED, NWilson::TTraceId traceId = {});
714+
NKikimrDataEvents::TEvWriteResult Write(TTestActorRuntime& runtime, TActorId sender, ui64 shardId, const TTableId& tableId, const TVector<TShardedTableOptions::TColumn>& columns, ui32 rowCount, ui64 txId, NKikimrDataEvents::TEvWrite::ETxMode txMode, NKikimrDataEvents::TEvWriteResult::EStatus expectedStatus = NKikimrDataEvents::TEvWriteResult::STATUS_UNSPECIFIED, NWilson::TTraceId traceId = {});
715715

716716
void UploadRows(TTestActorRuntime& runtime, const TString& tablePath, const TVector<std::pair<TString, Ydb::Type_PrimitiveTypeId>>& types, const TVector<TCell>& keys, const TVector<TCell>& values);
717717

0 commit comments

Comments
 (0)