我们如何在 apache beam sql 中使用 row_number()答案

【问题标题】：How can we use row_number() in apache beam sql我们如何在 apache beam sql 中使用 row_number()
【发布时间】：2019-09-17 04:22:17
【问题描述】：

我试过了，但出现以下错误。例如：

SELECT RELEASE_ORDER_KEY,ORDER_LINE_KEY,ORDER_HEADER_KEY,ROW_NUMBER() OVER (PARTITION BY ORDER_LINE_KEY ORDER BY RELEASE_ORDER_KEY) row_num FROM OMS_DATALAKE_ORDER_RELEASE_TAX ORDER BY ORDER_LINE_KEY LIMIT 5

错误：

线程“主”java.lang.RuntimeException 中的异常：无法翻译调用 ROW_NUMBER() OVER（PARTITION BY $t1 ORDER BY $t0 ROWS BETWEEN UNBounded PRECEDING AND CURRENT ROW）

【问题讨论】：

你有解决办法吗？

标签： google-cloud-dataflow apache-beam beam-sql

【解决方案1】：

BeamSQL 不支持 ROW_NUMBER() 函数（至少在 2.15 之前）。

【讨论】：

你好 Rui，Beam SQL 现在可以使用 row_number() 了吗？
目前还没有。今年六月可能会有支持（有人可以开始在issues.apache.org/jira/browse/BEAM-9198上工作）
你好 Rui，现在 Beam SQL 中添加了 row_number() 吗？
您好。 issues.apache.org/jira/browse/BEAM-9198 正在由 GSoC 学生实施。 row_number 可能很快就会实现。
目前 Beam master 分支支持 row_number。