我正在尝试row_number
使用带有以下代码的 Apache Beam SQL 生成:
PCollection<Row> rwrtg =
PCollectionTuple.of(new TupleTag<>("trrtg"), rrtg)
.apply(SqlTransform.query("select appId, row_number() over (partition by appId order by rating asc) as issue_rank from trrtg"));
但是出现以下错误:
java.lang.RuntimeException: cannot translate call ROW_NUMBER() OVER (PARTITION BY $t0 ORDER BY $t1 ROWS BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW)
你能建议如何解决这个问题吗?