Skip to content

Commit 7b9033a

Browse files
authored
Add SampleK (#6853)
1 parent c28ab83 commit 7b9033a

File tree

13 files changed

+1076
-349
lines changed

13 files changed

+1076
-349
lines changed

ydb/core/protos/tx_datashard.proto

Lines changed: 45 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1453,6 +1453,51 @@ message TEvBuildIndexProgressResponse {
14531453
optional uint64 RequestSeqNoRound = 13;
14541454
}
14551455

1456+
message TEvSampleKRequest {
1457+
optional uint64 Id = 1;
1458+
1459+
optional uint64 TabletId = 2;
1460+
optional NKikimrProto.TPathID PathId = 3;
1461+
1462+
optional uint64 K = 4;
1463+
optional uint64 Seed = 5;
1464+
1465+
repeated string Columns = 6;
1466+
optional NKikimrTx.TKeyRange KeyRange = 7;
1467+
1468+
optional uint64 SnapshotTxId = 8;
1469+
optional uint64 SnapshotStep = 9;
1470+
1471+
optional uint64 SeqNoGeneration = 10;
1472+
optional uint64 SeqNoRound = 11;
1473+
}
1474+
1475+
message TEvSampleKResponse {
1476+
optional uint64 Id = 1;
1477+
1478+
optional uint64 TabletId = 2;
1479+
optional NKikimrProto.TPathID PathId = 3;
1480+
1481+
enum EStatus {
1482+
INVALID = 0;
1483+
DONE = 1;
1484+
1485+
ABORTED = 2;
1486+
BAD_REQUEST = 3;
1487+
}
1488+
1489+
optional EStatus Status = 4;
1490+
repeated Ydb.Issue.IssueMessage Issues = 5;
1491+
1492+
optional NKikimrTx.TKeyRange RequestedKeyRange = 6;
1493+
1494+
optional uint64 RequestSeqNoGeneration = 7;
1495+
optional uint64 RequestSeqNoRound = 8;
1496+
1497+
repeated uint64 Probabilities = 9;
1498+
repeated bytes Rows = 10;
1499+
}
1500+
14561501
message TEvCdcStreamScanRequest {
14571502
message TLimits {
14581503
optional uint32 BatchMaxBytes = 1 [default = 512000];

0 commit comments

Comments
 (0)