summaryrefslogtreecommitdiffstats
path: root/yql/essentials/sql/v1/sql_match_recognize.h
diff options
context:
space:
mode:
authorvvvv <[email protected]>2024-11-07 12:29:36 +0300
committervvvv <[email protected]>2024-11-07 13:49:47 +0300
commitd4c258e9431675bab6745c8638df6e3dfd4dca6b (patch)
treeb5efcfa11351152a4c872fccaea35749141c0b11 /yql/essentials/sql/v1/sql_match_recognize.h
parent13a4f274caef5cfdaf0263b24e4d6bdd5521472b (diff)
Moved other yql/essentials libs YQL-19206
init commit_hash:7d4c435602078407bbf20dd3c32f9c90d2bbcbc0
Diffstat (limited to 'yql/essentials/sql/v1/sql_match_recognize.h')
-rw-r--r--yql/essentials/sql/v1/sql_match_recognize.h30
1 files changed, 30 insertions, 0 deletions
diff --git a/yql/essentials/sql/v1/sql_match_recognize.h b/yql/essentials/sql/v1/sql_match_recognize.h
new file mode 100644
index 00000000000..6766acc9537
--- /dev/null
+++ b/yql/essentials/sql/v1/sql_match_recognize.h
@@ -0,0 +1,30 @@
+#pragma once
+
+#include "sql_translation.h"
+#include "match_recognize.h"
+
+namespace NSQLTranslationV1 {
+
+using namespace NSQLv1Generated;
+
+class TSqlMatchRecognizeClause: public TSqlTranslation {
+public:
+ TSqlMatchRecognizeClause(TContext& ctx, NSQLTranslation::ESqlMode mode)
+ : TSqlTranslation(ctx, mode)
+ {}
+ TMatchRecognizeBuilderPtr CreateBuilder(const TRule_row_pattern_recognition_clause& node);
+private:
+ TVector<TNamedFunction> ParsePartitionBy(const TRule_window_partition_clause& partitionClause);
+ TNamedFunction ParseOneMeasure(const TRule_row_pattern_measure_definition& node);
+ TVector<TNamedFunction> ParseMeasures(const TRule_row_pattern_measure_list& node);
+ std::pair<TPosition, ERowsPerMatch> ParseRowsPerMatch(const TRule_row_pattern_rows_per_match& rowsPerMatchClause);
+ std::pair<TPosition, NYql::NMatchRecognize::TAfterMatchSkipTo> ParseAfterMatchSkipTo(const TRule_row_pattern_skip_to& skipToClause);
+ NYql::NMatchRecognize::TRowPatternTerm ParsePatternTerm(const TRule_row_pattern_term& node);
+ NYql::NMatchRecognize::TRowPattern ParsePattern(const TRule_row_pattern& node);
+ TNamedFunction ParseOneDefinition(const TRule_row_pattern_definition& node);
+ TVector<TNamedFunction> ParseDefinitions(const TRule_row_pattern_definition_list& node);
+private:
+ size_t PatternNestingLevel = 0;
+};
+
+} // namespace NSQLTranslationV1