如何使用 Apache Beam 在 Calcite SQL 中使用 LEAST 函数

问题描述

我正在尝试在我的 Apache Beam 管道中调用 Calcite sql 中的 LEAST 函数：

...,LEAST(12.5 + (25 * Quartile),100) AS PlayedPercentage
...

其中 Quartile 是一个 int32 列。我收到以下错误：

Caused by: org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.validate.sqlValidatorException: No match found for function signature LEAST(<NUMERIC>,<NUMERIC>)

我也尝试将两个参数都转换为 Float，但得到相同的结果。应该如何调用函数？

解决方法

根据Calcite's SQL Reference，LEAST 是方言特定的操作符，仅在 Oracle 操作符表中启用。

如果您直接连接到 Calcite，我建议在 JDBC 连接字符串中包含 fun=oracle，这将启用 Oracle 运算符表。如果您在 Beam 中使用方解石，我不确定这些步骤是什么。