0

我正在尝试使用 Beam SQL 进行简单的连接，但在编译时出现异常：

Exception in thread "main" java.lang.ClassCastException: org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.rex.RexCall cannot be cast to org.apache.beam.repackaged.beam_sdks_java_extensions_sql.org.apache.calcite.rex.RexInputRef

加入是这样的：

select T1.x from table1 T1 join table2 T2
on 
(case when T1.a = 'ABC' then 'ABC' else T1.b end = T2.c)

在 BigQuery 中执行时，此条件可以正常工作（尝试作为健全性检查）。不知道为什么它会破坏 Beam SQL。我什至尝试过使用 Beam SQL UDF，但它也没有帮助。我认为这是因为 Apache Calcite 及其遵循的格式，但我不知道如何处理它。

有人可以帮忙吗？

4

1 回答 1

0

有趣的。可以试试IF调理吗？我希望这会奏效：

select T1.x from table T1 join table T2 on IF(T1.a = 'ABC', 'ABC',T1.b) = T2.c
于 2019-02-12T18:02:19.120 回答