如何为 Calcite SQL 实现 Apache Beam UDF？

Question

我正在尝试在我的 Apache Beam 管道中实现一个简单的 BitwiseAnd 作为 SQL 的 UDF。这是简单的代码sn-p

public static class BitwiseAnd implements BeamSqlUdf {
    public static Integer eval(Integer input, Integer bit){
        return input & bit;
    }
}

但是，我收到以下错误：

No match found for function signature BitwiseAnd(<NUMERIC>, <NUMERIC>)

我也尝试在方法签名中使用 Long 并得到以下错误

没有找到适用于实际参数“java.lang.Integer, long”的构造函数/方法；候选人是：“public static java.lang.Long SqlTest$BitwiseAnd.eval(java.lang.Long, java.lang.Long)”

任何帮助将不胜感激。

Answer 1

看起来您正在使用此 UDF 的上下文期望签名是

public static Integer eval(Integer input, Long bit) { ... }

您也可以在 UDF 之前转换一侧以匹配另一侧的类型。