Skip to content

Commit 3aa1a41

Browse files
authored
Revert "Add ExecuteMode to YQL plugin for YT. Support validate and explain modes" (#1295)
1 parent 0d89c2e commit 3aa1a41

File tree

4 files changed

+10
-34
lines changed

4 files changed

+10
-34
lines changed

ydb/library/yql/yt/bridge/interface.h

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -96,10 +96,8 @@ using TFuncBridgeRun = TBridgeQueryResult*(
9696
const char* impersonationUser,
9797
const char* queryText,
9898
const char* settings,
99-
int settingsLength,
10099
const TBridgeQueryFile* files,
101-
int fileCount,
102-
int executeMode);
100+
int fileCount);
103101
using TFuncBridgeGetProgress = TBridgeQueryResult*(TBridgeYqlPlugin* plugin, const char* queryId);
104102
using TFuncBridgeAbort = TBridgeAbortResult*(TBridgeYqlPlugin* plugin, const char* queryId);
105103
using TFuncBridgeFreeAbortResult = void(TBridgeAbortResult* result);

ydb/library/yql/yt/dynamic/impl.cpp

Lines changed: 4 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@ extern "C" {
1212

1313
ssize_t BridgeGetAbiVersion()
1414
{
15-
return 2; // EYqlPluginAbiVersion
15+
return 1; // EYqlPluginAbiVersion::AbortQuery
1616
}
1717

1818
TBridgeYqlPlugin* BridgeCreateYqlPlugin(const TBridgeYqlPluginOptions* bridgeOptions)
@@ -74,10 +74,8 @@ TBridgeQueryResult* BridgeRun(
7474
const char* impersonationUser,
7575
const char* queryText,
7676
const char* settings,
77-
int settingsLength,
7877
const TBridgeQueryFile* bridgeFiles,
79-
int bridgeFileCount,
80-
int executeMode)
78+
int bridgeFileCount)
8179
{
8280
static const auto EmptyMap = TYsonString(TString("{}"));
8381

@@ -98,9 +96,8 @@ TBridgeQueryResult* BridgeRun(
9896
NYT::TGuid::FromString(queryId),
9997
TString(impersonationUser),
10098
TString(queryText),
101-
settings ? TYsonString(TString(settings, settingsLength)) : EmptyMap,
102-
files,
103-
executeMode);
99+
settings ? TYsonString(TString(settings)) : EmptyMap,
100+
files);
104101
FillString(bridgeResult->YsonResult, bridgeResult->YsonResultLength, result.YsonResult);
105102
FillString(bridgeResult->Plan, bridgeResult->PlanLength, result.Plan);
106103
FillString(bridgeResult->Statistics, bridgeResult->StatisticsLength, result.Statistics);

ydb/library/yql/yt/native/plugin.cpp

Lines changed: 4 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -254,8 +254,7 @@ class TYqlPlugin
254254
TString impersonationUser,
255255
TString queryText,
256256
TYsonString settings,
257-
std::vector<TQueryFile> files,
258-
int executeMode)
257+
std::vector<TQueryFile> files)
259258
{
260259
auto program = ProgramFactory_->Create("-memory-", queryText);
261260
{
@@ -315,23 +314,7 @@ class TYqlPlugin
315314
}
316315

317316
NYql::TProgram::TStatus status = NYql::TProgram::TStatus::Error;
318-
319-
// NYT::NYqlClient::EExecuteMode (yt/yt/ytlib/yql_client/public.h)
320-
switch (executeMode) {
321-
case 0: // Validate.
322-
status = program->Validate(impersonationUser, nullptr);
323-
break;
324-
case 1: // Optimize.
325-
status = program->OptimizeWithConfig(impersonationUser, pipelineConfigurator);
326-
break;
327-
case 2: // Run.
328-
status = program->RunWithConfig(impersonationUser, pipelineConfigurator);
329-
break;
330-
default: // Unknown.
331-
return TQueryResult{
332-
.YsonError = MessageToYtErrorYson(Format("Unknown execution mode: %v", executeMode)),
333-
};
334-
}
317+
status = program->RunWithConfig(impersonationUser, pipelineConfigurator);
335318

336319
if (status == NYql::TProgram::TStatus::Error) {
337320
return TQueryResult{
@@ -371,11 +354,10 @@ class TYqlPlugin
371354
TString impersonationUser,
372355
TString queryText,
373356
TYsonString settings,
374-
std::vector<TQueryFile> files,
375-
int executeMode) noexcept override
357+
std::vector<TQueryFile> files) noexcept override
376358
{
377359
try {
378-
return GuardedRun(queryId, impersonationUser, queryText, settings, files, executeMode);
360+
return GuardedRun(queryId, impersonationUser, queryText, settings, files);
379361
} catch (const std::exception& ex) {
380362
{
381363
auto guard = WriterGuard(ProgressSpinLock);

ydb/library/yql/yt/plugin.h

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -75,8 +75,7 @@ struct IYqlPlugin
7575
TString impersonationUser,
7676
TString queryText,
7777
NYson::TYsonString settings,
78-
std::vector<TQueryFile> files,
79-
int executeMode) noexcept = 0;
78+
std::vector<TQueryFile> files) noexcept = 0;
8079
virtual TQueryResult GetProgress(TQueryId queryId) noexcept = 0;
8180

8281
virtual TAbortResult Abort(TQueryId queryId) noexcept = 0;

0 commit comments

Comments
 (0)