在 Apache Beam 中进行 SQL 转换时如何将 int 转换为 boolean

问题描述

我正在尝试使用 Calcite sql 语法对 Apache Beam 进行 sql 转换。我正在做一个 int 到 boolean cast。我的 sql 看起来像这样：

,CASE WHEN cast(IsService as BOOLEAN) THEN CASE WHEN IsEligible THEN 1 ELSE 0 END ELSE NULL END AS Reported

其中 IsService 是一个 int 指标，IsEligible 是一个布尔值。

根据 documentation，从 int 到 boolean 的显式转换是可以的。 但是，运行管道时出现以下错误：

Caused by: org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.validate.sqlValidatorException: Cast function cannot convert value of type INTEGER to type BOOLEAN

谁能解释为什么我会收到错误消息？

解决方法

要立即解决您的问题，您可以使用 IsService > 0 而不是 CAST。在我看来，转换是什么就更清楚了。我不喜欢依赖“虚假”值。