Apache Beam SQL 中的 row_number

Question

我正在尝试使用带有以下代码的 Apache Beam SQL 生成 row_number：

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)

您能告诉我如何解决这个问题吗？

Answer 1

Beam SQL 支持两种方言：-

1. Beam Calcite - 有关支持的运算符的详细信息，请参见 here。
2. ZetaSQL - 有关支持的运算符的详细信息，请参见 here

目前这两种方言都不支持 row_number() 分析功能。因此你得到了错误。