如何解决如何使用 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 中使用方解石,我不确定这些步骤是什么。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。