Flink SQL match распознать вывод всех столбцов
Есть ли способ вывести все столбцы из предложения match_recognize MEASURES? Я пробовал следующие подходы:
1.
SELECT * FROM events MATCH_RECOGNIZE (PARTITION BY org_id ORDER BY proctime MEASURES A.* AS startId ONE ROW PER MATCH PATTERN (A C* B) DEFINE A AS A.tag = 'tag1', C AS C.tag <> 'tag2', B AS B.tag = 'tag2');
Я получил следующую ошибку:
org.apache.calcite.sql.validate.SqlValidatorException: Unknown field '*'
-
SELECT * FROM events MATCH_RECOGNIZE (PARTITION BY org_id ORDER BY proctime MEASURES A AS start ONE ROW PER MATCH PATTERN (A C* B) DEFINE A AS A.tag = 'tag1', C AS C.tag <> 'tag2', B AS B.tag = 'tag2');
Ошибка для этого была:
org.apache.flink.sql.parser.impl.ParseException: Encountered "start" at line 1, column 91.
Есть ли способ проделать эту операцию? или это не разрешено в flink SQL? Похоже, что документация по flink всегда говорит о простейших случаях и никогда не рассматривает сложные.