feat: analysis parser

include/common/ttokendef.h

@@ -69,335 +69,341 @@
 #define TK_NK_DOT                          51
 #define TK_WITH                            52
 #define TK_ENCRYPT_KEY                     53
-#define TK_DNODE                           54
+#define TK_ANODE                           54
-#define TK_PORT                            55
+#define TK_UPDATE                          55
-#define TK_DNODES                          56
+#define TK_ANODES                          56
-#define TK_RESTORE                         57
+#define TK_DNODE                           57
-#define TK_NK_IPTOKEN                      58
+#define TK_PORT                            58
-#define TK_FORCE                           59
+#define TK_DNODES                          59
-#define TK_UNSAFE                          60
+#define TK_RESTORE                         60
-#define TK_CLUSTER                         61
+#define TK_NK_IPTOKEN                      61
-#define TK_LOCAL                           62
+#define TK_FORCE                           62
-#define TK_QNODE                           63
+#define TK_UNSAFE                          63
-#define TK_BNODE                           64
+#define TK_CLUSTER                         64
-#define TK_SNODE                           65
+#define TK_LOCAL                           65
-#define TK_MNODE                           66
+#define TK_QNODE                           66
-#define TK_VNODE                           67
+#define TK_BNODE                           67
-#define TK_DATABASE                        68
+#define TK_SNODE                           68
-#define TK_USE                             69
+#define TK_MNODE                           69
-#define TK_FLUSH                           70
+#define TK_VNODE                           70
-#define TK_TRIM                            71
+#define TK_DATABASE                        71
-#define TK_S3MIGRATE                       72
+#define TK_USE                             72
-#define TK_COMPACT                         73
+#define TK_FLUSH                           73
-#define TK_IF                              74
+#define TK_TRIM                            74
-#define TK_NOT                             75
+#define TK_S3MIGRATE                       75
-#define TK_EXISTS                          76
+#define TK_COMPACT                         76
-#define TK_BUFFER                          77
+#define TK_IF                              77
-#define TK_CACHEMODEL                      78
+#define TK_NOT                             78
-#define TK_CACHESIZE                       79
+#define TK_EXISTS                          79
-#define TK_COMP                            80
+#define TK_BUFFER                          80
-#define TK_DURATION                        81
+#define TK_CACHEMODEL                      81
-#define TK_NK_VARIABLE                     82
+#define TK_CACHESIZE                       82
-#define TK_MAXROWS                         83
+#define TK_COMP                            83
-#define TK_MINROWS                         84
+#define TK_DURATION                        84
-#define TK_KEEP                            85
+#define TK_NK_VARIABLE                     85
-#define TK_PAGES                           86
+#define TK_MAXROWS                         86
-#define TK_PAGESIZE                        87
+#define TK_MINROWS                         87
-#define TK_TSDB_PAGESIZE                   88
+#define TK_KEEP                            88
-#define TK_PRECISION                       89
+#define TK_PAGES                           89
-#define TK_REPLICA                         90
+#define TK_PAGESIZE                        90
-#define TK_VGROUPS                         91
+#define TK_TSDB_PAGESIZE                   91
-#define TK_SINGLE_STABLE                   92
+#define TK_PRECISION                       92
-#define TK_RETENTIONS                      93
+#define TK_REPLICA                         93
-#define TK_SCHEMALESS                      94
+#define TK_VGROUPS                         94
-#define TK_WAL_LEVEL                       95
+#define TK_SINGLE_STABLE                   95
-#define TK_WAL_FSYNC_PERIOD                96
+#define TK_RETENTIONS                      96
-#define TK_WAL_RETENTION_PERIOD            97
+#define TK_SCHEMALESS                      97
-#define TK_WAL_RETENTION_SIZE              98
+#define TK_WAL_LEVEL                       98
-#define TK_WAL_ROLL_PERIOD                 99
+#define TK_WAL_FSYNC_PERIOD                99
-#define TK_WAL_SEGMENT_SIZE               100
+#define TK_WAL_RETENTION_PERIOD           100
-#define TK_STT_TRIGGER                    101
+#define TK_WAL_RETENTION_SIZE             101
-#define TK_TABLE_PREFIX                   102
+#define TK_WAL_ROLL_PERIOD                102
-#define TK_TABLE_SUFFIX                   103
+#define TK_WAL_SEGMENT_SIZE               103
-#define TK_S3_CHUNKSIZE                   104
+#define TK_STT_TRIGGER                    104
-#define TK_S3_KEEPLOCAL                   105
+#define TK_TABLE_PREFIX                   105
-#define TK_S3_COMPACT                     106
+#define TK_TABLE_SUFFIX                   106
-#define TK_KEEP_TIME_OFFSET               107
+#define TK_S3_CHUNKSIZE                   107
-#define TK_ENCRYPT_ALGORITHM              108
+#define TK_S3_KEEPLOCAL                   108
-#define TK_NK_COLON                       109
+#define TK_S3_COMPACT                     109
-#define TK_BWLIMIT                        110
+#define TK_KEEP_TIME_OFFSET               110
-#define TK_START                          111
+#define TK_ENCRYPT_ALGORITHM              111
-#define TK_TIMESTAMP                      112
+#define TK_NK_COLON                       112
-#define TK_END                            113
+#define TK_BWLIMIT                        113
-#define TK_TABLE                          114
+#define TK_START                          114
-#define TK_NK_LP                          115
+#define TK_TIMESTAMP                      115
-#define TK_NK_RP                          116
+#define TK_END                            116
-#define TK_USING                          117
+#define TK_TABLE                          117
-#define TK_FILE                           118
+#define TK_NK_LP                          118
-#define TK_STABLE                         119
+#define TK_NK_RP                          119
-#define TK_COLUMN                         120
+#define TK_USING                          120
-#define TK_MODIFY                         121
+#define TK_FILE                           121
-#define TK_RENAME                         122
+#define TK_STABLE                         122
-#define TK_TAG                            123
+#define TK_COLUMN                         123
-#define TK_SET                            124
+#define TK_MODIFY                         124
-#define TK_NK_EQ                          125
+#define TK_RENAME                         125
-#define TK_TAGS                           126
+#define TK_TAG                            126
-#define TK_BOOL                           127
+#define TK_SET                            127
-#define TK_TINYINT                        128
+#define TK_NK_EQ                          128
-#define TK_SMALLINT                       129
+#define TK_TAGS                           129
-#define TK_INT                            130
+#define TK_BOOL                           130
-#define TK_INTEGER                        131
+#define TK_TINYINT                        131
-#define TK_BIGINT                         132
+#define TK_SMALLINT                       132
-#define TK_FLOAT                          133
+#define TK_INT                            133
-#define TK_DOUBLE                         134
+#define TK_INTEGER                        134
-#define TK_BINARY                         135
+#define TK_BIGINT                         135
-#define TK_NCHAR                          136
+#define TK_FLOAT                          136
-#define TK_UNSIGNED                       137
+#define TK_DOUBLE                         137
-#define TK_JSON                           138
+#define TK_BINARY                         138
-#define TK_VARCHAR                        139
+#define TK_NCHAR                          139
-#define TK_MEDIUMBLOB                     140
+#define TK_UNSIGNED                       140
-#define TK_BLOB                           141
+#define TK_JSON                           141
-#define TK_VARBINARY                      142
+#define TK_VARCHAR                        142
-#define TK_GEOMETRY                       143
+#define TK_MEDIUMBLOB                     143
-#define TK_DECIMAL                        144
+#define TK_BLOB                           144
-#define TK_COMMENT                        145
+#define TK_VARBINARY                      145
-#define TK_MAX_DELAY                      146
+#define TK_GEOMETRY                       146
-#define TK_WATERMARK                      147
+#define TK_DECIMAL                        147
-#define TK_ROLLUP                         148
+#define TK_COMMENT                        148
-#define TK_TTL                            149
+#define TK_MAX_DELAY                      149
-#define TK_SMA                            150
+#define TK_WATERMARK                      150
-#define TK_DELETE_MARK                    151
+#define TK_ROLLUP                         151
-#define TK_FIRST                          152
+#define TK_TTL                            152
-#define TK_LAST                           153
+#define TK_SMA                            153
-#define TK_SHOW                           154
+#define TK_DELETE_MARK                    154
-#define TK_FULL                           155
+#define TK_FIRST                          155
-#define TK_PRIVILEGES                     156
+#define TK_LAST                           156
-#define TK_DATABASES                      157
+#define TK_SHOW                           157
-#define TK_TABLES                         158
+#define TK_FULL                           158
-#define TK_STABLES                        159
+#define TK_PRIVILEGES                     159
-#define TK_MNODES                         160
+#define TK_DATABASES                      160
-#define TK_QNODES                         161
+#define TK_TABLES                         161
-#define TK_ARBGROUPS                      162
+#define TK_STABLES                        162
-#define TK_FUNCTIONS                      163
+#define TK_MNODES                         163
-#define TK_INDEXES                        164
+#define TK_QNODES                         164
-#define TK_ACCOUNTS                       165
+#define TK_ARBGROUPS                      165
-#define TK_APPS                           166
+#define TK_FUNCTIONS                      166
-#define TK_CONNECTIONS                    167
+#define TK_INDEXES                        167
-#define TK_LICENCES                       168
+#define TK_ACCOUNTS                       168
-#define TK_GRANTS                         169
+#define TK_APPS                           169
-#define TK_LOGS                           170
+#define TK_CONNECTIONS                    170
-#define TK_MACHINES                       171
+#define TK_LICENCES                       171
-#define TK_ENCRYPTIONS                    172
+#define TK_GRANTS                         172
-#define TK_QUERIES                        173
+#define TK_LOGS                           173
-#define TK_SCORES                         174
+#define TK_MACHINES                       174
-#define TK_TOPICS                         175
+#define TK_ENCRYPTIONS                    175
-#define TK_VARIABLES                      176
+#define TK_QUERIES                        176
-#define TK_BNODES                         177
+#define TK_SCORES                         177
-#define TK_SNODES                         178
+#define TK_TOPICS                         178
-#define TK_TRANSACTIONS                   179
+#define TK_VARIABLES                      179
-#define TK_DISTRIBUTED                    180
+#define TK_BNODES                         180
-#define TK_CONSUMERS                      181
+#define TK_SNODES                         181
-#define TK_SUBSCRIPTIONS                  182
+#define TK_TRANSACTIONS                   182
-#define TK_VNODES                         183
+#define TK_DISTRIBUTED                    183
-#define TK_ALIVE                          184
+#define TK_CONSUMERS                      184
-#define TK_VIEWS                          185
+#define TK_SUBSCRIPTIONS                  185
-#define TK_VIEW                           186
+#define TK_VNODES                         186
-#define TK_COMPACTS                       187
+#define TK_ALIVE                          187
-#define TK_NORMAL                         188
+#define TK_VIEWS                          188
-#define TK_CHILD                          189
+#define TK_VIEW                           189
-#define TK_LIKE                           190
+#define TK_COMPACTS                       190
-#define TK_TBNAME                         191
+#define TK_NORMAL                         191
-#define TK_QTAGS                          192
+#define TK_CHILD                          192
-#define TK_AS                             193
+#define TK_LIKE                           193
-#define TK_SYSTEM                         194
+#define TK_TBNAME                         194
-#define TK_TSMA                           195
+#define TK_QTAGS                          195
-#define TK_INTERVAL                       196
+#define TK_AS                             196
-#define TK_RECURSIVE                      197
+#define TK_SYSTEM                         197
-#define TK_TSMAS                          198
+#define TK_TSMA                           198
-#define TK_FUNCTION                       199
+#define TK_INTERVAL                       199
-#define TK_INDEX                          200
+#define TK_RECURSIVE                      200
-#define TK_COUNT                          201
+#define TK_TSMAS                          201
-#define TK_LAST_ROW                       202
+#define TK_FUNCTION                       202
-#define TK_META                           203
+#define TK_INDEX                          203
-#define TK_ONLY                           204
+#define TK_COUNT                          204
-#define TK_TOPIC                          205
+#define TK_LAST_ROW                       205
-#define TK_CONSUMER                       206
+#define TK_META                           206
-#define TK_GROUP                          207
+#define TK_ONLY                           207
-#define TK_DESC                           208
+#define TK_TOPIC                          208
-#define TK_DESCRIBE                       209
+#define TK_CONSUMER                       209
-#define TK_RESET                          210
+#define TK_GROUP                          210
-#define TK_QUERY                          211
+#define TK_DESC                           211
-#define TK_CACHE                          212
+#define TK_DESCRIBE                       212
-#define TK_EXPLAIN                        213
+#define TK_RESET                          213
-#define TK_ANALYZE                        214
+#define TK_QUERY                          214
-#define TK_VERBOSE                        215
+#define TK_CACHE                          215
-#define TK_NK_BOOL                        216
+#define TK_EXPLAIN                        216
-#define TK_RATIO                          217
+#define TK_ANALYZE                        217
-#define TK_NK_FLOAT                       218
+#define TK_VERBOSE                        218
-#define TK_OUTPUTTYPE                     219
+#define TK_NK_BOOL                        219
-#define TK_AGGREGATE                      220
+#define TK_RATIO                          220
-#define TK_BUFSIZE                        221
+#define TK_NK_FLOAT                       221
-#define TK_LANGUAGE                       222
+#define TK_OUTPUTTYPE                     222
-#define TK_REPLACE                        223
+#define TK_AGGREGATE                      223
-#define TK_STREAM                         224
+#define TK_BUFSIZE                        224
-#define TK_INTO                           225
+#define TK_LANGUAGE                       225
-#define TK_PAUSE                          226
+#define TK_REPLACE                        226
-#define TK_RESUME                         227
+#define TK_STREAM                         227
-#define TK_PRIMARY                        228
+#define TK_INTO                           228
-#define TK_KEY                            229
+#define TK_PAUSE                          229
-#define TK_TRIGGER                        230
+#define TK_RESUME                         230
-#define TK_AT_ONCE                        231
+#define TK_PRIMARY                        231
-#define TK_WINDOW_CLOSE                   232
+#define TK_KEY                            232
-#define TK_IGNORE                         233
+#define TK_TRIGGER                        233
-#define TK_EXPIRED                        234
+#define TK_AT_ONCE                        234
-#define TK_FILL_HISTORY                   235
+#define TK_WINDOW_CLOSE                   235
-#define TK_UPDATE                         236
+#define TK_IGNORE                         236
-#define TK_SUBTABLE                       237
+#define TK_EXPIRED                        237
-#define TK_UNTREATED                      238
+#define TK_FILL_HISTORY                   238
-#define TK_KILL                           239
+#define TK_SUBTABLE                       239
-#define TK_CONNECTION                     240
+#define TK_UNTREATED                      240
-#define TK_TRANSACTION                    241
+#define TK_KILL                           241
-#define TK_BALANCE                        242
+#define TK_CONNECTION                     242
-#define TK_VGROUP                         243
+#define TK_TRANSACTION                    243
-#define TK_LEADER                         244
+#define TK_BALANCE                        244
-#define TK_MERGE                          245
+#define TK_VGROUP                         245
-#define TK_REDISTRIBUTE                   246
+#define TK_LEADER                         246
-#define TK_SPLIT                          247
+#define TK_MERGE                          247
-#define TK_DELETE                         248
+#define TK_REDISTRIBUTE                   248
-#define TK_INSERT                         249
+#define TK_SPLIT                          249
-#define TK_NK_BIN                         250
+#define TK_DELETE                         250
-#define TK_NK_HEX                         251
+#define TK_INSERT                         251
-#define TK_NULL                           252
+#define TK_NK_BIN                         252
-#define TK_NK_QUESTION                    253
+#define TK_NK_HEX                         253
-#define TK_NK_ALIAS                       254
+#define TK_NULL                           254
-#define TK_NK_ARROW                       255
+#define TK_NK_QUESTION                    255
-#define TK_ROWTS                          256
+#define TK_NK_ALIAS                       256
-#define TK_QSTART                         257
+#define TK_NK_ARROW                       257
-#define TK_QEND                           258
+#define TK_ROWTS                          258
-#define TK_QDURATION                      259
+#define TK_QSTART                         259
-#define TK_WSTART                         260
+#define TK_QEND                           260
-#define TK_WEND                           261
+#define TK_QDURATION                      261
-#define TK_WDURATION                      262
+#define TK_WSTART                         262
-#define TK_IROWTS                         263
+#define TK_WEND                           263
-#define TK_ISFILLED                       264
+#define TK_WDURATION                      264
-#define TK_CAST                           265
+#define TK_IROWTS                         265
-#define TK_POSITION                       266
+#define TK_ISFILLED                       266
-#define TK_IN                             267
+#define TK_FLOW                           267
-#define TK_FOR                            268
+#define TK_FHIGH                          268
-#define TK_NOW                            269
+#define TK_FROWTS                         269
-#define TK_TODAY                          270
+#define TK_CAST                           270
-#define TK_RAND                           271
+#define TK_POSITION                       271
-#define TK_SUBSTR                         272
+#define TK_IN                             272
-#define TK_SUBSTRING                      273
+#define TK_FOR                            273
-#define TK_BOTH                           274
+#define TK_NOW                            274
-#define TK_TRAILING                       275
+#define TK_TODAY                          275
-#define TK_LEADING                        276
+#define TK_RAND                           276
-#define TK_TIMEZONE                       277
+#define TK_SUBSTR                         277
-#define TK_CLIENT_VERSION                 278
+#define TK_SUBSTRING                      278
-#define TK_SERVER_VERSION                 279
+#define TK_BOTH                           279
-#define TK_SERVER_STATUS                  280
+#define TK_TRAILING                       280
-#define TK_CURRENT_USER                   281
+#define TK_LEADING                        281
-#define TK_PI                             282
+#define TK_TIMEZONE                       282
-#define TK_CASE                           283
+#define TK_CLIENT_VERSION                 283
-#define TK_WHEN                           284
+#define TK_SERVER_VERSION                 284
-#define TK_THEN                           285
+#define TK_SERVER_STATUS                  285
-#define TK_ELSE                           286
+#define TK_CURRENT_USER                   286
-#define TK_BETWEEN                        287
+#define TK_PI                             287
-#define TK_IS                             288
+#define TK_CASE                           288
-#define TK_NK_LT                          289
+#define TK_WHEN                           289
-#define TK_NK_GT                          290
+#define TK_THEN                           290
-#define TK_NK_LE                          291
+#define TK_ELSE                           291
-#define TK_NK_GE                          292
+#define TK_BETWEEN                        292
-#define TK_NK_NE                          293
+#define TK_IS                             293
-#define TK_MATCH                          294
+#define TK_NK_LT                          294
-#define TK_NMATCH                         295
+#define TK_NK_GT                          295
-#define TK_CONTAINS                       296
+#define TK_NK_LE                          296
-#define TK_JOIN                           297
+#define TK_NK_GE                          297
-#define TK_INNER                          298
+#define TK_NK_NE                          298
-#define TK_LEFT                           299
+#define TK_MATCH                          299
-#define TK_RIGHT                          300
+#define TK_NMATCH                         300
-#define TK_OUTER                          301
+#define TK_CONTAINS                       301
-#define TK_SEMI                           302
+#define TK_JOIN                           302
-#define TK_ANTI                           303
+#define TK_INNER                          303
-#define TK_ASOF                           304
+#define TK_LEFT                           304
-#define TK_WINDOW                         305
+#define TK_RIGHT                          305
-#define TK_WINDOW_OFFSET                  306
+#define TK_OUTER                          306
-#define TK_JLIMIT                         307
+#define TK_SEMI                           307
-#define TK_SELECT                         308
+#define TK_ANTI                           308
-#define TK_NK_HINT                        309
+#define TK_ASOF                           309
-#define TK_DISTINCT                       310
+#define TK_WINDOW                         310
-#define TK_WHERE                          311
+#define TK_WINDOW_OFFSET                  311
-#define TK_PARTITION                      312
+#define TK_JLIMIT                         312
-#define TK_BY                             313
+#define TK_SELECT                         313
-#define TK_SESSION                        314
+#define TK_NK_HINT                        314
-#define TK_STATE_WINDOW                   315
+#define TK_DISTINCT                       315
-#define TK_EVENT_WINDOW                   316
+#define TK_WHERE                          316
-#define TK_COUNT_WINDOW                   317
+#define TK_PARTITION                      317
-#define TK_SLIDING                        318
+#define TK_BY                             318
-#define TK_FILL                           319
+#define TK_SESSION                        319
-#define TK_VALUE                          320
+#define TK_STATE_WINDOW                   320
-#define TK_VALUE_F                        321
+#define TK_EVENT_WINDOW                   321
-#define TK_NONE                           322
+#define TK_COUNT_WINDOW                   322
-#define TK_PREV                           323
+#define TK_ANOMALY_WINDOW                 323
-#define TK_NULL_F                         324
+#define TK_SLIDING                        324
-#define TK_LINEAR                         325
+#define TK_FILL                           325
-#define TK_NEXT                           326
+#define TK_VALUE                          326
-#define TK_HAVING                         327
+#define TK_VALUE_F                        327
-#define TK_RANGE                          328
+#define TK_NONE                           328
-#define TK_EVERY                          329
+#define TK_PREV                           329
-#define TK_ORDER                          330
+#define TK_NULL_F                         330
-#define TK_SLIMIT                         331
+#define TK_LINEAR                         331
-#define TK_SOFFSET                        332
+#define TK_NEXT                           332
-#define TK_LIMIT                          333
+#define TK_HAVING                         333
-#define TK_OFFSET                         334
+#define TK_RANGE                          334
-#define TK_ASC                            335
+#define TK_EVERY                          335
-#define TK_NULLS                          336
+#define TK_ORDER                          336
-#define TK_ABORT                          337
+#define TK_SLIMIT                         337
-#define TK_AFTER                          338
+#define TK_SOFFSET                        338
-#define TK_ATTACH                         339
+#define TK_LIMIT                          339
-#define TK_BEFORE                         340
+#define TK_OFFSET                         340
-#define TK_BEGIN                          341
+#define TK_ASC                            341
-#define TK_BITAND                         342
+#define TK_NULLS                          342
-#define TK_BITNOT                         343
+#define TK_ABORT                          343
-#define TK_BITOR                          344
+#define TK_AFTER                          344
-#define TK_BLOCKS                         345
+#define TK_ATTACH                         345
-#define TK_CHANGE                         346
+#define TK_BEFORE                         346
-#define TK_COMMA                          347
+#define TK_BEGIN                          347
-#define TK_CONCAT                         348
+#define TK_BITAND                         348
-#define TK_CONFLICT                       349
+#define TK_BITNOT                         349
-#define TK_COPY                           350
+#define TK_BITOR                          350
-#define TK_DEFERRED                       351
+#define TK_BLOCKS                         351
-#define TK_DELIMITERS                     352
+#define TK_CHANGE                         352
-#define TK_DETACH                         353
+#define TK_COMMA                          353
-#define TK_DIVIDE                         354
+#define TK_CONCAT                         354
-#define TK_DOT                            355
+#define TK_CONFLICT                       355
-#define TK_EACH                           356
+#define TK_COPY                           356
-#define TK_FAIL                           357
+#define TK_DEFERRED                       357
-#define TK_GLOB                           358
+#define TK_DELIMITERS                     358
-#define TK_ID                             359
+#define TK_DETACH                         359
-#define TK_IMMEDIATE                      360
+#define TK_DIVIDE                         360
-#define TK_IMPORT                         361
+#define TK_DOT                            361
-#define TK_INITIALLY                      362
+#define TK_EACH                           362
-#define TK_INSTEAD                        363
+#define TK_FAIL                           363
-#define TK_ISNULL                         364
+#define TK_GLOB                           364
-#define TK_MODULES                        365
+#define TK_ID                             365
-#define TK_NK_BITNOT                      366
+#define TK_IMMEDIATE                      366
-#define TK_NK_SEMI                        367
+#define TK_IMPORT                         367
-#define TK_NOTNULL                        368
+#define TK_INITIALLY                      368
-#define TK_OF                             369
+#define TK_INSTEAD                        369
-#define TK_PLUS                           370
+#define TK_ISNULL                         370
-#define TK_PRIVILEGE                      371
+#define TK_MODULES                        371
-#define TK_RAISE                          372
+#define TK_NK_BITNOT                      372
-#define TK_RESTRICT                       373
+#define TK_NK_SEMI                        373
-#define TK_ROW                            374
+#define TK_NOTNULL                        374
-#define TK_STAR                           375
+#define TK_OF                             375
-#define TK_STATEMENT                      376
+#define TK_PLUS                           376
-#define TK_STRICT                         377
+#define TK_PRIVILEGE                      377
-#define TK_STRING                         378
+#define TK_RAISE                          378
-#define TK_TIMES                          379
+#define TK_RESTRICT                       379
-#define TK_VALUES                         380
+#define TK_ROW                            380
-#define TK_VARIABLE                       381
+#define TK_STAR                           381
-#define TK_WAL                            382
+#define TK_STATEMENT                      382
+#define TK_STRICT                         383
+#define TK_STRING                         384
+#define TK_TIMES                          385
+#define TK_VALUES                         386
+#define TK_VARIABLE                       387
+#define TK_WAL                            388
 
 #define TK_NK_SPACE   600
 #define TK_NK_COMMENT 601

source/libs/nodes/src/nodesCodeFuncs.c

@@ -97,6 +97,8 @@ const char* nodesNodeName(ENodeType type) {
       return "WindowOffset";
     case QUERY_NODE_COUNT_WINDOW:
       return "CountWindow";
+    case QUERY_NODE_ANOMALY_WINDOW:
+      return "AnomalyWindow";
     case QUERY_NODE_SET_OPERATOR:
       return "SetOperator";
     case QUERY_NODE_SELECT_STMT:
@@ -153,6 +155,12 @@ const char* nodesNodeName(ENodeType type) {
       return "CreateQnodeStmt";
     case QUERY_NODE_DROP_QNODE_STMT:
       return "DropQnodeStmt";
+    case QUERY_NODE_CREATE_ANODE_STMT:
+      return "CreateAnodeStmt";
+    case QUERY_NODE_DROP_ANODE_STMT:
+      return "DropAnodeStmt";
+    case QUERY_NODE_UPDATE_ANODE_STMT:
+      return "UpdateAnodeStmt";
     case QUERY_NODE_CREATE_SNODE_STMT:
       return "CreateSnodeStmt";
     case QUERY_NODE_DROP_SNODE_STMT:
@@ -213,6 +221,10 @@ const char* nodesNodeName(ENodeType type) {
       return "ShowModulesStmt";
     case QUERY_NODE_SHOW_QNODES_STMT:
       return "ShowQnodesStmt";
+    case QUERY_NODE_SHOW_ANODES_STMT:
+      return "ShowAnodesStmt";
+    case QUERY_NODE_SHOW_ANODES_FULL_STMT:
+      return "ShowAnodesFullStmt";
     case QUERY_NODE_SHOW_SNODES_STMT:
       return "ShowSnodesStmt";
     case QUERY_NODE_SHOW_BNODES_STMT:
@@ -328,6 +340,8 @@ const char* nodesNodeName(ENodeType type) {
       return "LogicIndefRowsFunc";
     case QUERY_NODE_LOGIC_PLAN_INTERP_FUNC:
       return "LogicInterpFunc";
+    case QUERY_NODE_LOGIC_PLAN_FORECAST_FUNC:
+      return "LogicForecastFunc";
     case QUERY_NODE_LOGIC_PLAN_GROUP_CACHE:
       return "LogicGroupCache";
     case QUERY_NODE_LOGIC_PLAN_DYN_QUERY_CTRL:
@@ -362,6 +376,10 @@ const char* nodesNodeName(ENodeType type) {
       return "PhysiMergeCountWindow";
     case QUERY_NODE_PHYSICAL_PLAN_STREAM_COUNT:
       return "PhysiStreamCountWindow";
+    case QUERY_NODE_PHYSICAL_PLAN_MERGE_ANOMALY:
+      return "PhysiMergeAnomalyWindow";
+    case QUERY_NODE_PHYSICAL_PLAN_STREAM_ANOMALY:
+      return "PhysiStreamAnomalyWindow";
     case QUERY_NODE_PHYSICAL_PLAN_PROJECT:
       return "PhysiProject";
     case QUERY_NODE_PHYSICAL_PLAN_MERGE_JOIN:
@@ -413,6 +431,8 @@ const char* nodesNodeName(ENodeType type) {
       return "PhysiIndefRowsFunc";
     case QUERY_NODE_PHYSICAL_PLAN_INTERP_FUNC:
       return "PhysiInterpFunc";
+    case QUERY_NODE_PHYSICAL_PLAN_FORECAST_FUNC:
+      return "PhysiForecastFunc";
     case QUERY_NODE_PHYSICAL_PLAN_DISPATCH:
       return "PhysiDispatch";
     case QUERY_NODE_PHYSICAL_PLAN_INSERT:
@@ -1260,6 +1280,30 @@ static int32_t jsonToLogicInterpFuncNode(const SJson* pJson, void* pObj) {
   return code;
 }
 
+static const char* jkForecastFuncLogicPlanFuncs = "Funcs";
+
+static int32_t logicForecastFuncNodeToJson(const void* pObj, SJson* pJson) {
+  const SForecastFuncLogicNode* pNode = (const SForecastFuncLogicNode*)pObj;
+
+  int32_t code = logicPlanNodeToJson(pObj, pJson);
+  if (TSDB_CODE_SUCCESS == code) {
+    code = nodeListToJson(pJson, jkForecastFuncLogicPlanFuncs, pNode->pFuncs);
+  }
+
+  return code;
+}
+
+static int32_t jsonToLogicForecastFuncNode(const SJson* pJson, void* pObj) {
+  SForecastFuncLogicNode* pNode = (SForecastFuncLogicNode*)pObj;
+
+  int32_t code = jsonToLogicPlanNode(pJson, pObj);
+  if (TSDB_CODE_SUCCESS == code) {
+    code = jsonToNodeList(pJson, jkForecastFuncLogicPlanFuncs, &pNode->pFuncs);
+  }
+
+  return code;
+}
+
 static const char* jkGroupCacheLogicPlanGrpColsMayBeNull = "GroupColsMayBeNull";
 static const char* jkGroupCacheLogicPlanGroupByUid = "GroupByUid";
 static const char* jkGroupCacheLogicPlanGlobalGroup = "GlobalGroup";
@@ -3011,6 +3055,36 @@ static int32_t jsonToPhysiCountWindowNode(const SJson* pJson, void* pObj) {
   return code;
 }
 
+static const char* jkAnomalyWindowPhysiPlanAnomalyKey = "AnomalyKey";
+static const char* jkAnomalyWindowPhysiPlanAnomalyOption = "AnomalyOpt";
+
+static int32_t physiAnomalyWindowNodeToJson(const void* pObj, SJson* pJson) {
+  const SAnomalyWindowPhysiNode* pNode = (const SAnomalyWindowPhysiNode*)pObj;
+
+  int32_t code = physiWindowNodeToJson(pObj, pJson);
+  if (TSDB_CODE_SUCCESS == code) {
+    code = tjsonAddObject(pJson, jkAnomalyWindowPhysiPlanAnomalyKey, nodeToJson, pNode->pAnomalyKey);
+  }
+  if (TSDB_CODE_SUCCESS == code) {
+    code = tjsonAddStringToObject(pJson, jkAnomalyWindowPhysiPlanAnomalyOption, pNode->anomalyOpt);
+  }
+  return code;
+}
+
+static int32_t jsonToPhysiAnomalyWindowNode(const SJson* pJson, void* pObj) {
+  SAnomalyWindowPhysiNode* pNode = (SAnomalyWindowPhysiNode*)pObj;
+
+  int32_t code = jsonToPhysiWindowNode(pJson, pObj);
+  if (TSDB_CODE_SUCCESS == code) {
+    code = jsonToNodeObject(pJson, jkAnomalyWindowPhysiPlanAnomalyKey, &pNode->pAnomalyKey);
+  }
+  if (TSDB_CODE_SUCCESS == code) {
+    code = tjsonGetStringValue(pJson, jkAnomalyWindowPhysiPlanAnomalyOption, pNode->anomalyOpt);
+  }
+
+  return code;
+}
+
 static const char* jkPartitionPhysiPlanExprs = "Exprs";
 static const char* jkPartitionPhysiPlanPartitionKeys = "PartitionKeys";
 static const char* jkPartitionPhysiPlanTargets = "Targets";
@@ -3198,6 +3272,37 @@ static int32_t jsonToPhysiInterpFuncNode(const SJson* pJson, void* pObj) {
   return code;
 }
 
+static const char* jkForecastFuncPhysiPlanExprs = "Exprs";
+static const char* jkForecastFuncPhysiPlanFuncs = "Funcs";
+
+static int32_t physiForecastFuncNodeToJson(const void* pObj, SJson* pJson) {
+  const SForecastFuncPhysiNode* pNode = (const SForecastFuncPhysiNode*)pObj;
+
+  int32_t code = physicPlanNodeToJson(pObj, pJson);
+  if (TSDB_CODE_SUCCESS == code) {
+    code = nodeListToJson(pJson, jkForecastFuncPhysiPlanExprs, pNode->pExprs);
+  }
+  if (TSDB_CODE_SUCCESS == code) {
+    code = nodeListToJson(pJson, jkForecastFuncPhysiPlanFuncs, pNode->pFuncs);
+  }
+
+  return code;
+}
+
+static int32_t jsonToPhysiForecastFuncNode(const SJson* pJson, void* pObj) {
+  SForecastFuncPhysiNode* pNode = (SForecastFuncPhysiNode*)pObj;
+
+  int32_t code = jsonToPhysicPlanNode(pJson, pObj);
+  if (TSDB_CODE_SUCCESS == code) {
+    code = jsonToNodeList(pJson, jkForecastFuncPhysiPlanExprs, &pNode->pExprs);
+  }
+  if (TSDB_CODE_SUCCESS == code) {
+    code = jsonToNodeList(pJson, jkForecastFuncPhysiPlanFuncs, &pNode->pFuncs);
+  }
+
+  return code;
+}
+
 static const char* jkDataSinkInputDataBlockDesc = "InputDataBlockDesc";
 
 static int32_t physicDataSinkNodeToJson(const void* pObj, SJson* pJson) {
@@ -4763,6 +4868,36 @@ static int32_t jsonToCountWindowNode(const SJson* pJson, void* pObj) {
   return code;
 }
 
+static const char* jkAnomalyWindowTsPrimaryKey = "AnomalyTsPrimaryKey";
+static const char* jkAnomalyWindowExpr = "AnomalyWindowExpr";
+static const char* jkAnomalyWindowOption = "AnomalyWindowOpt";
+
+static int32_t anomalyWindowNodeToJson(const void* pObj, SJson* pJson) {
+  const SAnomalyWindowNode* pNode = (const SAnomalyWindowNode*)pObj;
+
+  int32_t code = tjsonAddObject(pJson, jkAnomalyWindowTsPrimaryKey, nodeToJson, pNode->pCol);
+  if (TSDB_CODE_SUCCESS == code) {
+    code = tjsonAddObject(pJson, jkAnomalyWindowExpr, nodeToJson, pNode->pExpr);
+  }
+  if (TSDB_CODE_SUCCESS == code) {
+    code = tjsonAddStringToObject(pJson, jkAnomalyWindowOption, pNode->anomalyOpt);
+  }
+  return code;
+}
+
+static int32_t jsonToAnomalyWindowNode(const SJson* pJson, void* pObj) {
+  SAnomalyWindowNode* pNode = (SAnomalyWindowNode*)pObj;
+
+  int32_t code = jsonToNodeObject(pJson, jkAnomalyWindowTsPrimaryKey, &pNode->pCol);
+  if (TSDB_CODE_SUCCESS == code) {
+    code = jsonToNodeObject(pJson, jkAnomalyWindowExpr, (SNode**)&pNode->pExpr);
+  }
+  if (TSDB_CODE_SUCCESS == code) {
+    code = tjsonGetStringValue(pJson, jkAnomalyWindowOption, pNode->anomalyOpt);
+  }
+  return code;
+}
+
 static const char* jkIntervalWindowInterval = "Interval";
 static const char* jkIntervalWindowOffset = "Offset";
 static const char* jkIntervalWindowSliding = "Sliding";
@@ -6449,6 +6584,39 @@ static int32_t dropQnodeStmtToJson(const void* pObj, SJson* pJson) { return drop
 
 static int32_t jsonToDropQnodeStmt(const SJson* pJson, void* pObj) { return jsonToDropComponentNodeStmt(pJson, pObj); }
 
+static const char* jkCreateAnodeStmtUrl = "Url";
+static const char*  jkUpdateDropANodeStmtId = "AnodeId";
+
+static int32_t createAnodeStmtToJson(const void* pObj, SJson* pJson) {
+  const SCreateAnodeStmt* pNode = (const SCreateAnodeStmt*)pObj;
+  return tjsonAddStringToObject(pJson, jkCreateAnodeStmtUrl, pNode->url);
+}
+
+static int32_t jsonToCreateAnodeStmt(const SJson* pJson, void* pObj) {
+  SCreateAnodeStmt* pNode = (SCreateAnodeStmt*)pObj;
+  return tjsonGetStringValue(pJson, jkCreateAnodeStmtUrl, pNode->url);
+}
+
+static int32_t updateAnodeStmtToJson(const void* pObj, SJson* pJson) {
+  const SUpdateAnodeStmt* pNode = (const SUpdateAnodeStmt*)pObj;
+  return tjsonAddIntegerToObject(pJson, jkUpdateDropANodeStmtId, pNode->anodeId);
+}
+
+static int32_t jsonToUpdateAnodeStmt(const SJson* pJson, void* pObj) {
+  SUpdateAnodeStmt* pNode = (SUpdateAnodeStmt*)pObj;
+  return tjsonGetIntValue(pJson, jkUpdateDropANodeStmtId, &pNode->anodeId);
+}
+
+static int32_t dropAnodeStmtToJson(const void* pObj, SJson* pJson) {
+  const SDropAnodeStmt* pNode = (const SDropAnodeStmt*)pObj;
+  return tjsonAddIntegerToObject(pJson, jkUpdateDropANodeStmtId, pNode->anodeId);
+}
+
+static int32_t jsonToDropAnodeStmt(const SJson* pJson, void* pObj) {
+  SDropAnodeStmt* pNode = (SDropAnodeStmt*)pObj;
+  return tjsonGetIntValue(pJson, jkUpdateDropANodeStmtId, &pNode->anodeId);
+}
+
 static int32_t createSnodeStmtToJson(const void* pObj, SJson* pJson) {
   return createComponentNodeStmtToJson(pObj, pJson);
 }
@@ -7014,6 +7182,14 @@ static int32_t showQnodesStmtToJson(const void* pObj, SJson* pJson) { return sho
 
 static int32_t jsonToShowQnodesStmt(const SJson* pJson, void* pObj) { return jsonToShowStmt(pJson, pObj); }
 
+static int32_t showAnodesStmtToJson(const void* pObj, SJson* pJson) { return showStmtToJson(pObj, pJson); }
+
+static int32_t jsonToShowAnodesStmt(const SJson* pJson, void* pObj) { return jsonToShowStmt(pJson, pObj); }
+
+static int32_t showAnodesFullStmtToJson(const void* pObj, SJson* pJson) { return showStmtToJson(pObj, pJson); }
+
+static int32_t jsonToShowAnodesFullStmt(const SJson* pJson, void* pObj) { return jsonToShowStmt(pJson, pObj); }
+
 static int32_t showArbGroupsStmtToJson(const void* pObj, SJson* pJson) { return showStmtToJson(pObj, pJson); }
 
 static int32_t jsonToShowArbGroupsStmt(const SJson* pJson, void* pObj) { return jsonToShowStmt(pJson, pObj); }
@@ -7550,6 +7726,8 @@ static int32_t specificNodeToJson(const void* pObj, SJson* pJson) {
       return windowOffsetNodeToJson(pObj, pJson);
     case QUERY_NODE_COUNT_WINDOW:
       return countWindowNodeToJson(pObj, pJson);
+    case QUERY_NODE_ANOMALY_WINDOW:
+      return anomalyWindowNodeToJson(pObj, pJson);
     case QUERY_NODE_SET_OPERATOR:
       return setOperatorToJson(pObj, pJson);
     case QUERY_NODE_SELECT_STMT:
@@ -7602,6 +7780,12 @@ static int32_t specificNodeToJson(const void* pObj, SJson* pJson) {
       return createQnodeStmtToJson(pObj, pJson);
     case QUERY_NODE_DROP_QNODE_STMT:
       return dropQnodeStmtToJson(pObj, pJson);
+    case QUERY_NODE_CREATE_ANODE_STMT:
+      return createAnodeStmtToJson(pObj, pJson);
+    case QUERY_NODE_DROP_ANODE_STMT:
+      return dropAnodeStmtToJson(pObj, pJson);
+    case QUERY_NODE_UPDATE_ANODE_STMT:
+      return updateAnodeStmtToJson(pObj, pJson);
     case QUERY_NODE_CREATE_SNODE_STMT:
       return createSnodeStmtToJson(pObj, pJson);
     case QUERY_NODE_DROP_SNODE_STMT:
@@ -7652,6 +7836,10 @@ static int32_t specificNodeToJson(const void* pObj, SJson* pJson) {
       return showMnodesStmtToJson(pObj, pJson);
     case QUERY_NODE_SHOW_QNODES_STMT:
       return showQnodesStmtToJson(pObj, pJson);
+    case QUERY_NODE_SHOW_ANODES_STMT:
+      return showAnodesStmtToJson(pObj, pJson);
+    case QUERY_NODE_SHOW_ANODES_FULL_STMT:
+      return showAnodesFullStmtToJson(pObj, pJson);
     case QUERY_NODE_SHOW_ARBGROUPS_STMT:
       return showArbGroupsStmtToJson(pObj, pJson);
     case QUERY_NODE_SHOW_CLUSTER_STMT:
@@ -7741,6 +7929,8 @@ static int32_t specificNodeToJson(const void* pObj, SJson* pJson) {
       return logicIndefRowsFuncNodeToJson(pObj, pJson);
     case QUERY_NODE_LOGIC_PLAN_INTERP_FUNC:
       return logicInterpFuncNodeToJson(pObj, pJson);
+    case QUERY_NODE_LOGIC_PLAN_FORECAST_FUNC:
+      return logicForecastFuncNodeToJson(pObj, pJson);
     case QUERY_NODE_LOGIC_PLAN_GROUP_CACHE:
       return logicGroupCacheNodeToJson(pObj, pJson);
     case QUERY_NODE_LOGIC_PLAN_DYN_QUERY_CTRL:
@@ -7801,6 +7991,8 @@ static int32_t specificNodeToJson(const void* pObj, SJson* pJson) {
     case QUERY_NODE_PHYSICAL_PLAN_MERGE_COUNT:
     case QUERY_NODE_PHYSICAL_PLAN_STREAM_COUNT:
       return physiCountWindowNodeToJson(pObj, pJson);
+    case QUERY_NODE_PHYSICAL_PLAN_MERGE_ANOMALY:
+      return physiAnomalyWindowNodeToJson(pObj, pJson);
     case QUERY_NODE_PHYSICAL_PLAN_PARTITION:
       return physiPartitionNodeToJson(pObj, pJson);
     case QUERY_NODE_PHYSICAL_PLAN_STREAM_PARTITION:
@@ -7809,6 +8001,8 @@ static int32_t specificNodeToJson(const void* pObj, SJson* pJson) {
       return physiIndefRowsFuncNodeToJson(pObj, pJson);
     case QUERY_NODE_PHYSICAL_PLAN_INTERP_FUNC:
       return physiInterpFuncNodeToJson(pObj, pJson);
+    case QUERY_NODE_PHYSICAL_PLAN_FORECAST_FUNC:
+      return physiForecastFuncNodeToJson(pObj, pJson);
     case QUERY_NODE_PHYSICAL_PLAN_DISPATCH:
       return physiDispatchNodeToJson(pObj, pJson);
     case QUERY_NODE_PHYSICAL_PLAN_INSERT:
@@ -7900,6 +8094,8 @@ static int32_t jsonToSpecificNode(const SJson* pJson, void* pObj) {
       return jsonToWindowOffsetNode(pJson, pObj);
     case QUERY_NODE_COUNT_WINDOW:
       return jsonToCountWindowNode(pJson, pObj);
+    case QUERY_NODE_ANOMALY_WINDOW:
+      return jsonToAnomalyWindowNode(pJson, pObj);
     case QUERY_NODE_SET_OPERATOR:
       return jsonToSetOperator(pJson, pObj);
     case QUERY_NODE_SELECT_STMT:
@@ -8002,6 +8198,10 @@ static int32_t jsonToSpecificNode(const SJson* pJson, void* pObj) {
       return jsonToShowMnodesStmt(pJson, pObj);
     case QUERY_NODE_SHOW_QNODES_STMT:
       return jsonToShowQnodesStmt(pJson, pObj);
+    case QUERY_NODE_SHOW_ANODES_STMT:
+      return jsonToShowAnodesStmt(pJson, pObj);
+    case QUERY_NODE_SHOW_ANODES_FULL_STMT:
+      return jsonToShowAnodesFullStmt(pJson, pObj);
     case QUERY_NODE_SHOW_ARBGROUPS_STMT:
       return jsonToShowArbGroupsStmt(pJson, pObj);
     case QUERY_NODE_SHOW_CLUSTER_STMT:
@@ -8099,6 +8299,8 @@ static int32_t jsonToSpecificNode(const SJson* pJson, void* pObj) {
       return jsonToLogicIndefRowsFuncNode(pJson, pObj);
     case QUERY_NODE_LOGIC_PLAN_INTERP_FUNC:
       return jsonToLogicInterpFuncNode(pJson, pObj);
+    case QUERY_NODE_LOGIC_PLAN_FORECAST_FUNC:
+      return jsonToLogicForecastFuncNode(pJson, pObj);
     case QUERY_NODE_LOGIC_PLAN_GROUP_CACHE:
       return jsonToLogicGroupCacheNode(pJson, pObj);
     case QUERY_NODE_LOGIC_PLAN_DYN_QUERY_CTRL:
@@ -8159,6 +8361,8 @@ static int32_t jsonToSpecificNode(const SJson* pJson, void* pObj) {
     case QUERY_NODE_PHYSICAL_PLAN_MERGE_COUNT:
     case QUERY_NODE_PHYSICAL_PLAN_STREAM_COUNT:
       return jsonToPhysiCountWindowNode(pJson, pObj);
+    case QUERY_NODE_PHYSICAL_PLAN_MERGE_ANOMALY:
+      return jsonToPhysiAnomalyWindowNode(pJson, pObj);
     case QUERY_NODE_PHYSICAL_PLAN_PARTITION:
       return jsonToPhysiPartitionNode(pJson, pObj);
     case QUERY_NODE_PHYSICAL_PLAN_STREAM_PARTITION:
@@ -8167,6 +8371,8 @@ static int32_t jsonToSpecificNode(const SJson* pJson, void* pObj) {
       return jsonToPhysiIndefRowsFuncNode(pJson, pObj);
     case QUERY_NODE_PHYSICAL_PLAN_INTERP_FUNC:
       return jsonToPhysiInterpFuncNode(pJson, pObj);
+    case QUERY_NODE_PHYSICAL_PLAN_FORECAST_FUNC:
+      return jsonToPhysiForecastFuncNode(pJson, pObj);
     case QUERY_NODE_PHYSICAL_PLAN_DISPATCH:
       return jsonToPhysiDispatchNode(pJson, pObj);
     case QUERY_NODE_PHYSICAL_PLAN_QUERY_INSERT:

source/libs/parser/inc/sql.y

@@ -157,6 +157,12 @@ with_clause_opt(A) ::= WITH search_condition(B).
 /************************************************ create encrypt_key *********************************************/
 cmd ::= CREATE ENCRYPT_KEY NK_STRING(A).                                          { pCxt->pRootNode = createEncryptKeyStmt(pCxt, &A); }
 
+/************************************************ create drop update anode ***************************************/
+cmd ::= CREATE ANODE NK_STRING(A).                                                { pCxt->pRootNode = createCreateAnodeStmt(pCxt, &A); }
+cmd ::= UPDATE ANODE NK_INTEGER(A).                                               { pCxt->pRootNode = createUpdateAnodeStmt(pCxt, &A, false); }
+cmd ::= UPDATE ALL ANODES.                                                        { pCxt->pRootNode = createUpdateAnodeStmt(pCxt, NULL, true); }
+cmd ::= DROP ANODE NK_INTEGER(A).                                                 { pCxt->pRootNode = createDropAnodeStmt(pCxt, &A); }
+
 /************************************************ create/drop/alter/restore dnode *********************************************/
 cmd ::= CREATE DNODE dnode_endpoint(A).                                           { pCxt->pRootNode = createCreateDnodeStmt(pCxt, &A, NULL); }
 cmd ::= CREATE DNODE dnode_endpoint(A) PORT NK_INTEGER(B).                        { pCxt->pRootNode = createCreateDnodeStmt(pCxt, &A, &B); }
@@ -524,6 +530,8 @@ cmd ::= SHOW db_name_cond_opt(A) VGROUPS.
 cmd ::= SHOW MNODES.                                                              { pCxt->pRootNode = createShowStmt(pCxt, QUERY_NODE_SHOW_MNODES_STMT); }
 //cmd ::= SHOW MODULES.                                                             { pCxt->pRootNode = createShowStmt(pCxt, QUERY_NODE_SHOW_MODULES_STMT); }
 cmd ::= SHOW QNODES.                                                              { pCxt->pRootNode = createShowStmt(pCxt, QUERY_NODE_SHOW_QNODES_STMT); }
+cmd ::= SHOW ANODES.                                                              { pCxt->pRootNode = createShowStmt(pCxt, QUERY_NODE_SHOW_ANODES_STMT); }
+cmd ::= SHOW ANODES FULL.                                                         { pCxt->pRootNode = createShowStmt(pCxt, QUERY_NODE_SHOW_ANODES_FULL_STMT); }
 cmd ::= SHOW ARBGROUPS.                                                           { pCxt->pRootNode = createShowStmt(pCxt, QUERY_NODE_SHOW_ARBGROUPS_STMT); }
 cmd ::= SHOW FUNCTIONS.                                                           { pCxt->pRootNode = createShowStmt(pCxt, QUERY_NODE_SHOW_FUNCTIONS_STMT); }
 cmd ::= SHOW INDEXES FROM table_name_cond(A) from_db_opt(B).                      { pCxt->pRootNode = createShowStmtWithCond(pCxt, QUERY_NODE_SHOW_INDEXES_STMT, B, A, OP_TYPE_EQUAL); }
@@ -1187,6 +1195,9 @@ pseudo_column(A) ::= WDURATION(B).
 pseudo_column(A) ::= IROWTS(B).                                                   { A = createRawExprNode(pCxt, &B, createFunctionNode(pCxt, &B, NULL)); }
 pseudo_column(A) ::= ISFILLED(B).                                                 { A = createRawExprNode(pCxt, &B, createFunctionNode(pCxt, &B, NULL)); }
 pseudo_column(A) ::= QTAGS(B).                                                    { A = createRawExprNode(pCxt, &B, createFunctionNode(pCxt, &B, NULL)); }
+pseudo_column(A) ::= FLOW(B).                                                     { A = createRawExprNode(pCxt, &B, createFunctionNode(pCxt, &B, NULL)); }
+pseudo_column(A) ::= FHIGH(B).                                                    { A = createRawExprNode(pCxt, &B, createFunctionNode(pCxt, &B, NULL)); }
+pseudo_column(A) ::= FROWTS(B).                                                   { A = createRawExprNode(pCxt, &B, createFunctionNode(pCxt, &B, NULL)); }
 
 function_expression(A) ::= function_name(B) NK_LP expression_list(C) NK_RP(D).                        { A = createRawExprNodeExt(pCxt, &B, &D, createFunctionNode(pCxt, &B, C)); }
 function_expression(A) ::= star_func(B) NK_LP star_func_para_list(C) NK_RP(D).                        { A = createRawExprNodeExt(pCxt, &B, &D, createFunctionNode(pCxt, &B, C)); }
@@ -1505,6 +1516,10 @@ twindow_clause_opt(A) ::=
   COUNT_WINDOW NK_LP NK_INTEGER(B) NK_RP.                                         { A = createCountWindowNode(pCxt, &B, &B); }
 twindow_clause_opt(A) ::=
   COUNT_WINDOW NK_LP NK_INTEGER(B) NK_COMMA NK_INTEGER(C) NK_RP.                  { A = createCountWindowNode(pCxt, &B, &C); }
+twindow_clause_opt(A) ::=
+  ANOMALY_WINDOW NK_LP expr_or_subquery(B) NK_RP.                                 { A = createAnomalyWindowNode(pCxt, releaseRawExprNode(pCxt, B), NULL); }
+twindow_clause_opt(A) ::=
+  ANOMALY_WINDOW NK_LP expr_or_subquery(B) NK_COMMA NK_STRING(C) NK_RP.           { A = createAnomalyWindowNode(pCxt, releaseRawExprNode(pCxt, B), &C); }
 
 sliding_opt(A) ::= .                                                              { A = NULL; }
 sliding_opt(A) ::= SLIDING NK_LP interval_sliding_duration_literal(B) NK_RP.      { A = releaseRawExprNode(pCxt, B); }

source/libs/parser/src/parTokenizer.c

@@ -38,6 +38,9 @@ static SKeyword keywordTable[] = {
     {"ANALYZE",              TK_ANALYZE},
     {"AND",                  TK_AND},
     {"ANTI",                 TK_ANTI},
+    {"ANODE",                TK_ANODE},
+    {"ANODES",               TK_ANODES},
+    {"ANOMALY_WINDOW",       TK_ANOMALY_WINDOW},
 //    {"ANY",                  TK_ANY},
     {"APPS",                 TK_APPS},
     {"AS",                   TK_AS},
@@ -332,6 +335,9 @@ static SKeyword keywordTable[] = {
     {"_WDURATION",           TK_WDURATION},
     {"_WEND",                TK_WEND},
     {"_WSTART",              TK_WSTART},
+    {"_FLOW",                TK_FLOW},
+    {"_FHIGH",               TK_FHIGH},
+    {"_FROWTS",              TK_FROWTS},
     {"ALIVE",                TK_ALIVE},
     {"VARBINARY",            TK_VARBINARY},
     {"S3_CHUNKSIZE",         TK_S3_CHUNKSIZE},