Watermarks: DDL

commit_hash:64ad6b4138ee27f474b440e8ef3e07fac1935346

1 files changed, 3 insertions, 0 deletions

diff --git a/yql/essentials/sql/v1/complete/sql_complete_ut.cpp b/yql/essentials/sql/v1/complete/sql_complete_ut.cpp
index 604af6008d9..bffe15a869b 100644
--- a/yql/essentials/sql/v1/complete/sql_complete_ut.cpp
+++ b/yql/essentials/sql/v1/complete/sql_complete_ut.cpp
@@ -932,6 +932,7 @@ Y_UNIT_TEST_SUITE(SqlCompleteTests) {
             TVector<TCandidate> expected = {
                 {Keyword, "COLUMNS"},
                 {Keyword, "SCHEMA"},
+                {Keyword, "WATERMARK AS()", 1},
                 {HintName, "XLOCK"},
             };
             UNIT_ASSERT_VALUES_EQUAL(Complete(engine, "REDUCE my_table WITH "), expected);
@@ -940,6 +941,7 @@ Y_UNIT_TEST_SUITE(SqlCompleteTests) {
             TVector<TCandidate> expected = {
                 {Keyword, "COLUMNS"},
                 {Keyword, "SCHEMA"},
+                {Keyword, "WATERMARK AS()", 1},
                 {HintName, "XLOCK"},
             };
             UNIT_ASSERT_VALUES_EQUAL(Complete(engine, "SELECT key FROM my_table WITH "), expected);
@@ -951,6 +953,7 @@ Y_UNIT_TEST_SUITE(SqlCompleteTests) {
             {Keyword, "COLUMNS"},
             {HintName, "EXPIRATION"},
             {Keyword, "SCHEMA"},
+            {Keyword, "WATERMARK AS()", 1},
         };
 
         auto engine = MakeSqlCompletionEngineUT();