diff options
| author | dinmukhammed <dinmukhammed@yandex-team.ru> | 2022-04-19 03:16:15 +0300 |
|---|---|---|
| committer | dinmukhammed <dinmukhammed@yandex-team.ru> | 2022-04-19 03:16:15 +0300 |
| commit | 4845626417f39f8db2d17cb91f35621ec2b77d9b (patch) | |
| tree | 08b74f7dcc796dc1dbf32e5eb66cb4d7135b468b | |
| parent | 9c4137c3a261361cf7ad9e022470203dc8de58b9 (diff) | |
| download | ydb-4845626417f39f8db2d17cb91f35621ec2b77d9b.tar.gz | |
Revert PR:2476942
Revert commit
ref:f6dd42ffa13860404d711ca4929d0a1e85e98ab3
| -rw-r--r-- | ydb/library/yql/providers/dq/provider/exec/yql_dq_exectransformer.cpp | 18 |
1 files changed, 4 insertions, 14 deletions
diff --git a/ydb/library/yql/providers/dq/provider/exec/yql_dq_exectransformer.cpp b/ydb/library/yql/providers/dq/provider/exec/yql_dq_exectransformer.cpp index 2772e1b55b..e4c29bef40 100644 --- a/ydb/library/yql/providers/dq/provider/exec/yql_dq_exectransformer.cpp +++ b/ydb/library/yql/providers/dq/provider/exec/yql_dq_exectransformer.cpp @@ -382,18 +382,10 @@ private: switch (block->Type) { case EUserDataType::URL: case EUserDataType::PATH: { - TString content = fullFileName; - if (name == TStringBuf("FileContent")) { - if (block->FrozenFile->GetSize() < MaxFileReadSize) { - content = TFileInput(block->FrozenFile->GetPath()).ReadAll(); - } else { - TCallableBuilder builder(typeEnv, TStringBuf("FileContentJob"), callable.GetType()->GetReturnType(), false); - builder.Add(pgmBuilder.NewDataLiteral<NUdf::EDataSlot::String>(fullFileName)); - result = TRuntimeNode(builder.Build(), false); - } - } - if (!result) - result = pgmBuilder.NewDataLiteral<NUdf::EDataSlot::String>(content); + TString content = (name == TStringBuf("FilePath")) + ? fullFileName + : TFileInput(block->FrozenFile->GetPath()).ReadAll(); + result = pgmBuilder.NewDataLiteral<NUdf::EDataSlot::String>(content); break; } case EUserDataType::RAW_INLINE_DATA: { @@ -1266,8 +1258,6 @@ private: THolder<IGraphTransformer> DqTypeAnnotationTransformer; mutable THashMap<TString, TFileLinkPtr> FileLinks; mutable THashMap<TString, TString> ModulesMapping; - - const ui64 MaxFileReadSize = 1_MB; }; } |