Skip to content

Commit 30a0f87

Browse files
mpereskokovamaVovk
mpereskokova
authored and
maVovk
committed
YT-23942: GetDeclaredParametersInfo -> GetQueryDeclaredParametersInfo
commit_hash:38ae30b19ea6d75729ce97c028f73326ba29493a
1 parent a00028e commit 30a0f87

File tree

12 files changed

+26
-26
lines changed

12 files changed

+26
-26
lines changed

‎yt/yt/client/api/delegating_client.h‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -828,8 +828,8 @@ class TDelegatingClient
828828
const TGetQueryTrackerInfoOptions& options),
829829
(options))
830830

831-
DELEGATE_METHOD(TFuture<TGetDeclaredParametersInfoResult>, GetDeclaredParametersInfo, (
832-
const TGetDeclaredParametersInfoOptions& options),
831+
DELEGATE_METHOD(TFuture<TGetQueryDeclaredParametersInfoResult>, GetQueryDeclaredParametersInfo, (
832+
const TGetQueryDeclaredParametersInfoOptions& options),
833833
(options))
834834

835835
// Bundle Controller

‎yt/yt/client/api/query_tracker_client.h‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -186,7 +186,7 @@ struct TGetQueryTrackerInfoResult
186186
std::optional<int> ExpectedTablesVersion;
187187
};
188188

189-
struct TGetDeclaredParametersInfoOptions
189+
struct TGetQueryDeclaredParametersInfoOptions
190190
: public TTimeoutOptions
191191
, public TQueryTrackerOptions
192192
{
@@ -195,7 +195,7 @@ struct TGetDeclaredParametersInfoOptions
195195
NQueryTrackerClient::EQueryEngine Engine;
196196
};
197197

198-
struct TGetDeclaredParametersInfoResult
198+
struct TGetQueryDeclaredParametersInfoResult
199199
{
200200
NYson::TYsonString Parameters;
201201
};
@@ -237,7 +237,7 @@ struct IQueryTrackerClient
237237

238238
virtual TFuture<TGetQueryTrackerInfoResult> GetQueryTrackerInfo(const TGetQueryTrackerInfoOptions& options = {}) = 0;
239239

240-
virtual TFuture<TGetDeclaredParametersInfoResult> GetDeclaredParametersInfo(const TGetDeclaredParametersInfoOptions& options = {}) = 0;
240+
virtual TFuture<TGetQueryDeclaredParametersInfoResult> GetQueryDeclaredParametersInfo(const TGetQueryDeclaredParametersInfoOptions& options = {}) = 0;
241241
};
242242

243243
////////////////////////////////////////////////////////////////////////////////

‎yt/yt/client/api/rpc_proxy/api_service_proxy.h‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -211,7 +211,7 @@ class TApiServiceProxy
211211
DEFINE_RPC_PROXY_METHOD(NRpcProxy::NProto, ListQueries);
212212
DEFINE_RPC_PROXY_METHOD(NRpcProxy::NProto, AlterQuery);
213213
DEFINE_RPC_PROXY_METHOD(NRpcProxy::NProto, GetQueryTrackerInfo);
214-
DEFINE_RPC_PROXY_METHOD(NRpcProxy::NProto, GetDeclaredParametersInfo);
214+
DEFINE_RPC_PROXY_METHOD(NRpcProxy::NProto, GetQueryDeclaredParametersInfo);
215215

216216
// Distributed table client
217217
DEFINE_RPC_PROXY_METHOD(NRpcProxy::NProto, StartDistributedWriteSession);

‎yt/yt/client/api/rpc_proxy/client_impl.cpp‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -2644,12 +2644,12 @@ TFuture<TGetQueryTrackerInfoResult> TClient::GetQueryTrackerInfo(
26442644
}));
26452645
}
26462646

2647-
TFuture<TGetDeclaredParametersInfoResult> TClient::GetDeclaredParametersInfo(
2648-
const TGetDeclaredParametersInfoOptions& options)
2647+
TFuture<TGetQueryDeclaredParametersInfoResult> TClient::GetQueryDeclaredParametersInfo(
2648+
const TGetQueryDeclaredParametersInfoOptions& options)
26492649
{
26502650
auto proxy = CreateApiServiceProxy();
26512651

2652-
auto req = proxy.GetDeclaredParametersInfo();
2652+
auto req = proxy.GetQueryDeclaredParametersInfo();
26532653
SetTimeoutOptions(*req, options);
26542654

26552655
req->set_query_tracker_stage(options.QueryTrackerStage);
@@ -2661,8 +2661,8 @@ TFuture<TGetDeclaredParametersInfoResult> TClient::GetDeclaredParametersInfo(
26612661
req->set_query(options.Query);
26622662
req->set_engine(NProto::ConvertQueryEngineToProto(options.Engine));
26632663

2664-
return req->Invoke().Apply(BIND([] (const TApiServiceProxy::TRspGetDeclaredParametersInfoPtr& rsp) {
2665-
return TGetDeclaredParametersInfoResult{
2664+
return req->Invoke().Apply(BIND([] (const TApiServiceProxy::TRspGetQueryDeclaredParametersInfoPtr& rsp) {
2665+
return TGetQueryDeclaredParametersInfoResult{
26662666
.Parameters = TYsonString(rsp->declared_parameters_info()),
26672667
};
26682668
}));

‎yt/yt/client/api/rpc_proxy/client_impl.h‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -528,8 +528,8 @@ class TClient
528528
TFuture<TGetQueryTrackerInfoResult> GetQueryTrackerInfo(
529529
const TGetQueryTrackerInfoOptions& options = {}) override;
530530

531-
TFuture<TGetDeclaredParametersInfoResult> GetDeclaredParametersInfo(
532-
const TGetDeclaredParametersInfoOptions& options = {}) override;
531+
TFuture<TGetQueryDeclaredParametersInfoResult> GetQueryDeclaredParametersInfo(
532+
const TGetQueryDeclaredParametersInfoOptions& options = {}) override;
533533

534534
// Authentication
535535

‎yt/yt/client/driver/driver.cpp‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -386,7 +386,7 @@ class TDriver
386386
REGISTER (TReadQueryResultCommand, "read_query_result", Null, Tabular, false, true , ApiVersion4);
387387
REGISTER (TAlterQueryCommand, "alter_query", Null, Tabular, true, false, ApiVersion4);
388388
REGISTER (TGetQueryTrackerInfoCommand, "get_query_tracker_info", Null, Structured, false, false, ApiVersion4);
389-
REGISTER (TGetDeclaredParametersInfoCommand, "get_declared_parameters_info", Null, Structured, false, false, ApiVersion4);
389+
REGISTER (TGetQueryDeclaredParametersInfoCommand, "get_query_declared_parameters_info", Null, Structured, false, false, ApiVersion4);
390390

391391
REGISTER_ALL(TGetBundleConfigCommand, "get_bundle_config", Null, Structured, false, false);
392392
REGISTER_ALL(TSetBundleConfigCommand, "set_bundle_config", Structured, Null, true, false);

‎yt/yt/client/driver/query_commands.cpp‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -443,7 +443,7 @@ void TGetQueryTrackerInfoCommand::DoExecute(ICommandContextPtr context)
443443

444444
////////////////////////////////////////////////////////////////////////////////
445445

446-
void TGetDeclaredParametersInfoCommand::Register(TRegistrar registrar)
446+
void TGetQueryDeclaredParametersInfoCommand::Register(TRegistrar registrar)
447447
{
448448
registrar.ParameterWithUniversalAccessor<std::string>(
449449
"stage",
@@ -474,9 +474,9 @@ void TGetDeclaredParametersInfoCommand::Register(TRegistrar registrar)
474474
.Optional(/*init*/ false);
475475
}
476476

477-
void TGetDeclaredParametersInfoCommand::DoExecute(ICommandContextPtr context)
477+
void TGetQueryDeclaredParametersInfoCommand::DoExecute(ICommandContextPtr context)
478478
{
479-
auto result = WaitFor(context->GetClient()->GetDeclaredParametersInfo(Options))
479+
auto result = WaitFor(context->GetClient()->GetQueryDeclaredParametersInfo(Options))
480480
.ValueOrThrow();
481481

482482
context->ProduceOutputValue(BuildYsonStringFluently()

‎yt/yt/client/driver/query_commands.h‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -137,11 +137,11 @@ class TGetQueryTrackerInfoCommand
137137

138138
////////////////////////////////////////////////////////////////////////////////
139139

140-
class TGetDeclaredParametersInfoCommand
141-
: public TTypedCommand<NApi::TGetDeclaredParametersInfoOptions>
140+
class TGetQueryDeclaredParametersInfoCommand
141+
: public TTypedCommand<NApi::TGetQueryDeclaredParametersInfoOptions>
142142
{
143143
public:
144-
REGISTER_YSON_STRUCT_LITE(TGetDeclaredParametersInfoCommand);
144+
REGISTER_YSON_STRUCT_LITE(TGetQueryDeclaredParametersInfoCommand);
145145

146146
static void Register(TRegistrar registrar);
147147

‎yt/yt/client/federated/client.cpp‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -484,7 +484,7 @@ class TClient
484484
UNIMPLEMENTED_METHOD(TFuture<TListQueriesResult>, ListQueries, (const TListQueriesOptions&));
485485
UNIMPLEMENTED_METHOD(TFuture<void>, AlterQuery, (NQueryTrackerClient::TQueryId, const TAlterQueryOptions&));
486486
UNIMPLEMENTED_METHOD(TFuture<TGetQueryTrackerInfoResult>, GetQueryTrackerInfo, (const TGetQueryTrackerInfoOptions&));
487-
UNIMPLEMENTED_METHOD(TFuture<TGetDeclaredParametersInfoResult>, GetDeclaredParametersInfo, (const TGetDeclaredParametersInfoOptions&));
487+
UNIMPLEMENTED_METHOD(TFuture<TGetQueryDeclaredParametersInfoResult>, GetQueryDeclaredParametersInfo, (const TGetQueryDeclaredParametersInfoOptions&));
488488
UNIMPLEMENTED_METHOD(TFuture<NBundleControllerClient::TBundleConfigDescriptorPtr>, GetBundleConfig, (const std::string&, const NBundleControllerClient::TGetBundleConfigOptions&));
489489
UNIMPLEMENTED_METHOD(TFuture<void>, SetBundleConfig, (const std::string&, const NBundleControllerClient::TBundleTargetConfigPtr&, const NBundleControllerClient::TSetBundleConfigOptions&));
490490
UNIMPLEMENTED_METHOD(TFuture<ITableReaderPtr>, CreateTableReader, (const NYPath::TRichYPath&, const TTableReaderOptions&));

‎yt/yt/client/hedging/hedging.cpp‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -227,7 +227,7 @@ class THedgingClient
227227
UNSUPPORTED_METHOD(TFuture<TListQueriesResult>, ListQueries, (const TListQueriesOptions&));
228228
UNSUPPORTED_METHOD(TFuture<void>, AlterQuery, (NQueryTrackerClient::TQueryId, const TAlterQueryOptions&));
229229
UNSUPPORTED_METHOD(TFuture<TGetQueryTrackerInfoResult>, GetQueryTrackerInfo, (const TGetQueryTrackerInfoOptions&));
230-
UNSUPPORTED_METHOD(TFuture<TGetDeclaredParametersInfoResult>, GetDeclaredParametersInfo, (const TGetDeclaredParametersInfoOptions&));
230+
UNSUPPORTED_METHOD(TFuture<TGetQueryDeclaredParametersInfoResult>, GetQueryDeclaredParametersInfo, (const TGetQueryDeclaredParametersInfoOptions&));
231231
UNSUPPORTED_METHOD(TFuture<NBundleControllerClient::TBundleConfigDescriptorPtr>, GetBundleConfig, (const std::string&, const NBundleControllerClient::TGetBundleConfigOptions&));
232232
UNSUPPORTED_METHOD(TFuture<TGetPipelineSpecResult>, GetPipelineSpec, (const NYPath::TYPath&, const TGetPipelineSpecOptions&));
233233
UNSUPPORTED_METHOD(TFuture<TSetPipelineSpecResult>, SetPipelineSpec, (const NYPath::TYPath&, const NYson::TYsonString&, const TSetPipelineSpecOptions&));

0 commit comments

Comments
 (0)