Hi,
Is there a way to output all columns from match_recognize MEASURES clause ?
I have tried following approaches :
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');/
The error I got is : /org.apache.calcite.sql.validate.SqlValidatorException:
Unknown field '*'/
2. /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');/
The error for this was : /org.apache.flink.sql.parser.impl.ParseException:
Encountered "start" at line 1, column 91./
Is there any way to do this operation ? or is it not allowed in flink SQL ?
Seems like the flink documentation always talks about simplest cases and
never considers any complex cases.
--
Sent from:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
Locked
