aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorapollo1321 <apollo1321@yandex-team.com>2024-12-10 18:18:05 +0300
committerapollo1321 <apollo1321@yandex-team.com>2024-12-10 18:52:27 +0300
commit1cd90f1eb816df00bddcea4bf1d5dd3563a86209 (patch)
tree0f3f1304421cbf77e2fdb2ec38d8ebaa0d5cf093
parent5d2412cc89288570d72485a840dfc464dddb1cd6 (diff)
downloadydb-1cd90f1eb816df00bddcea4bf1d5dd3563a86209.tar.gz
Fix issues in rXXXXXX
commit_hash:e2368dba2bbcbe620269ca0e3609246e8aa3f998
-rw-r--r--yt/yt/client/api/shuffle_client.cpp14
-rw-r--r--yt/yt/client/api/shuffle_client.h2
2 files changed, 16 insertions, 0 deletions
diff --git a/yt/yt/client/api/shuffle_client.cpp b/yt/yt/client/api/shuffle_client.cpp
index 65e7af27d40..00128bc2982 100644
--- a/yt/yt/client/api/shuffle_client.cpp
+++ b/yt/yt/client/api/shuffle_client.cpp
@@ -6,6 +6,20 @@ using namespace NYson;
////////////////////////////////////////////////////////////////////////////////
+void FormatValue(TStringBuilderBase* builder, const TShuffleHandlePtr& shuffleHandle, TStringBuf /*spec*/)
+{
+ builder->AppendFormat(
+ "{TransactionId: %v, CoordinatorAddress: %v, Account: %v, MediumName: %v, PartitionCount: %v, ReplicationFactor: %v}",
+ shuffleHandle->TransactionId,
+ shuffleHandle->CoordinatorAddress,
+ shuffleHandle->Account,
+ shuffleHandle->MediumName,
+ shuffleHandle->PartitionCount,
+ shuffleHandle->ReplicationFactor);
+}
+
+////////////////////////////////////////////////////////////////////////////////
+
void TShuffleHandle::Register(TRegistrar registrar)
{
registrar.Parameter("transaction_id", &TThis::TransactionId);
diff --git a/yt/yt/client/api/shuffle_client.h b/yt/yt/client/api/shuffle_client.h
index ed4c0ec783b..a2398789523 100644
--- a/yt/yt/client/api/shuffle_client.h
+++ b/yt/yt/client/api/shuffle_client.h
@@ -23,6 +23,8 @@ struct TShuffleHandle
DEFINE_REFCOUNTED_TYPE(TShuffleHandle)
+void FormatValue(TStringBuilderBase* builder, const TShuffleHandlePtr& shuffleHandle, TStringBuf spec);
+
////////////////////////////////////////////////////////////////////////////////
struct TStartShuffleOptions