Skip to content

Commit 1cd90f1

Browse files
committed
Fix issues in rXXXXXX
commit_hash:e2368dba2bbcbe620269ca0e3609246e8aa3f998
1 parent 5d2412c commit 1cd90f1

File tree

2 files changed

+16
-0
lines changed

2 files changed

+16
-0
lines changed

yt/yt/client/api/shuffle_client.cpp

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,20 @@ using namespace NYson;
66

77
////////////////////////////////////////////////////////////////////////////////
88

9+
void FormatValue(TStringBuilderBase* builder, const TShuffleHandlePtr& shuffleHandle, TStringBuf /*spec*/)
10+
{
11+
builder->AppendFormat(
12+
"{TransactionId: %v, CoordinatorAddress: %v, Account: %v, MediumName: %v, PartitionCount: %v, ReplicationFactor: %v}",
13+
shuffleHandle->TransactionId,
14+
shuffleHandle->CoordinatorAddress,
15+
shuffleHandle->Account,
16+
shuffleHandle->MediumName,
17+
shuffleHandle->PartitionCount,
18+
shuffleHandle->ReplicationFactor);
19+
}
20+
21+
////////////////////////////////////////////////////////////////////////////////
22+
923
void TShuffleHandle::Register(TRegistrar registrar)
1024
{
1125
registrar.Parameter("transaction_id", &TThis::TransactionId);

yt/yt/client/api/shuffle_client.h

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,8 @@ struct TShuffleHandle
2323

2424
DEFINE_REFCOUNTED_TYPE(TShuffleHandle)
2525

26+
void FormatValue(TStringBuilderBase* builder, const TShuffleHandlePtr& shuffleHandle, TStringBuf spec);
27+
2628
////////////////////////////////////////////////////////////////////////////////
2729

2830
struct TStartShuffleOptions

0 commit comments

Comments
 (0)