google-cloud-dataflow - 我们如何在 apache beam sql 中使用 row_number()

Question

我试过了，但得到以下错误。例如：

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)

Answer 1

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