diff options
| author | vokayndzop <vokayndzop@yandex-team.com> | 2024-12-16 15:55:05 +0300 |
|---|---|---|
| committer | vokayndzop <vokayndzop@yandex-team.com> | 2024-12-16 16:34:36 +0300 |
| commit | b1cde7dcb055fb6f3367e81fd0f57bd55b8bb93c (patch) | |
| tree | 230bddb8bb4ce7d8290a16a4465ec98dbf513a5a /yql/essentials/minikql/mkql_program_builder.h | |
| parent | 88e0ad5922cea1349ec1f8cbf133524cf865d696 (diff) | |
| download | ydb-b1cde7dcb055fb6f3367e81fd0f57bd55b8bb93c.tar.gz | |
MR: support ALL ROWS PER MATCH
commit_hash:9e2ba38d0d523bb870f6dc76717a3bec5d8ffadc
Diffstat (limited to 'yql/essentials/minikql/mkql_program_builder.h')
| -rw-r--r-- | yql/essentials/minikql/mkql_program_builder.h | 11 |
1 files changed, 7 insertions, 4 deletions
diff --git a/yql/essentials/minikql/mkql_program_builder.h b/yql/essentials/minikql/mkql_program_builder.h index 762d3a013e..9e6b0d97d0 100644 --- a/yql/essentials/minikql/mkql_program_builder.h +++ b/yql/essentials/minikql/mkql_program_builder.h @@ -712,12 +712,15 @@ public: TRuntimeNode MatchRecognizeCore( TRuntimeNode inputStream, const TUnaryLambda& getPartitionKeySelectorNode, - const TArrayRef<TStringBuf>& partitionColumns, - const TArrayRef<std::pair<TStringBuf, TBinaryLambda>>& getMeasures, + const TArrayRef<TStringBuf>& partitionColumnNames, + const TVector<TStringBuf>& measureColumnNames, + const TVector<TBinaryLambda>& getMeasures, const NYql::NMatchRecognize::TRowPattern& pattern, - const TArrayRef<std::pair<TStringBuf, TTernaryLambda>>& getDefines, + const TVector<TStringBuf>& defineVarNames, + const TVector<TTernaryLambda>& getDefines, bool streamingMode, - const NYql::NMatchRecognize::TAfterMatchSkipTo& skipTo + const NYql::NMatchRecognize::TAfterMatchSkipTo& skipTo, + NYql::NMatchRecognize::ERowsPerMatch rowsPerMatch ); TRuntimeNode TimeOrderRecover( |