如何解决Flink SQL 匹配识别输出所有列
有没有办法从 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',B AS B.tag = 'tag2');
这个错误是:org.apache.flink.sql.parser.impl.ParseException: Encountered "start" at line 1,column 91.
有没有办法做这个操作?还是在 flink SQL 中不允许? 好像flink的文档总是讲最简单的情况,从不考虑复杂的情况。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。