diff options
author | vokayndzop <vokayndzop@yandex-team.com> | 2024-12-19 12:21:46 +0300 |
---|---|---|
committer | vokayndzop <vokayndzop@yandex-team.com> | 2024-12-19 13:20:38 +0300 |
commit | 3eb1b593d4536bad103af0e92fa83391d53f5398 (patch) | |
tree | 6bfe37d95402cc2dfe4e506477eeee6258a3f606 /yql/essentials/minikql/mkql_program_builder.cpp | |
parent | 72e5d59e4685dd66c0ecb0f845a3871e3e3d2a40 (diff) | |
download | ydb-3eb1b593d4536bad103af0e92fa83391d53f5398.tar.gz |
MR: support ALL ROWS PER MATCH fix
commit_hash:e83ac5f9c7e523e798d64dc5262a6b3e07e1bb7f
Diffstat (limited to 'yql/essentials/minikql/mkql_program_builder.cpp')
-rw-r--r-- | yql/essentials/minikql/mkql_program_builder.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/yql/essentials/minikql/mkql_program_builder.cpp b/yql/essentials/minikql/mkql_program_builder.cpp index 0b9197024d..895f2d590a 100644 --- a/yql/essentials/minikql/mkql_program_builder.cpp +++ b/yql/essentials/minikql/mkql_program_builder.cpp @@ -6243,7 +6243,7 @@ TRuntimeNode TProgramBuilder::MatchRecognizeCore( callableBuilder.Add(NewDataLiteral(static_cast<i32>(skipTo.To))); callableBuilder.Add(NewDataLiteral<NUdf::EDataSlot::String>(skipTo.Var)); } - if constexpr (RuntimeVersion >= 53U) { + if constexpr (RuntimeVersion >= 54U) { callableBuilder.Add(NewDataLiteral(static_cast<i32>(rowsPerMatch))); callableBuilder.Add(NewList(outputColumnEntryType, outputColumnOrder)); } |