Flink-1.11 Table API &符号 语法问题

[nashcen]

在Flink-1.11 中，关于Table API的 select、filter方法，官方推荐语法，用$符号替换原来的"
<http://apache-flink.147419.n8.nabble.com/file/t817/QE%7ED%40%29AG9%5B%259309QVO5GSNW.png>

但是我在IDEA里，按照官方API的示例去写，$符号不生效，这是什么原因？
<http://apache-flink.147419.n8.nabble.com/file/t817/OVSY%40FGDO6XDKZL79V5%7DH2D.png>



--
Sent from: http://apache-flink.147419.n8.nabble.com/

[Leonard Xu]

Hi

>
> 在Flink-1.11 中，关于Table API的 select、filter方法，官方推荐语法，用$符号替换原来的"
> <http://apache-flink.147419.n8.nabble.com/file/t817/QE%7ED%40%29AG9%5B%259309QVO5GSNW.png>
>
> 但是我在IDEA里，按照官方API的示例去写，$符号不生效，这是什么原因？
> <http://apache-flink.147419.n8.nabble.com/file/t817/OVSY%40FGDO6XDKZL79V5%7DH2D.png>

 看你用的scala，scala里推荐的应该是：$”a” 这种写法吧[1], 文档上得tab区分了scala和java的，在java 和scala中$()都是个方法名，$“a” 是scala里的方法访问的一个隐式转换。在1.11前应该是单引号’a, 不是双引号，也是用于构造Expression的一种方式。

即使用$(”a” )在scala中也应该是ok的，可以贴下报错信息吗？

Best
Leonard
[1] https://ci.apache.org/projects/flink/flink-docs-master/dev/table/tableApi.html <https://ci.apache.org/projects/flink/flink-docs-master/dev/table/tableApi.html>

[nashcen]

语法提示错误，就没有运行。在你们的IDEA里面，1.11 Table API 的& 写法，是否显示正常？



--
Sent from: http://apache-flink.147419.n8.nabble.com/

[Leonard Xu]

Hi,

可以的，我看了下，你可以把你异常和可以复现的代码贴下吗？

祝好,
Leonard


> 在 2020年9月22日，09:44，nashcen <[hidden email]> 写道：
>
> 语法提示错误，就没有运行。在你们的IDEA里面，1.11 Table API 的& 写法，是否显示正常？
>
>
>
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/

[nobleyd]

首先确保你是1.11，因为1.10没有$函数。其次确保你import了$函数，在org.apache.flink.table.api.
Expressions类中。

Leonard Xu <[hidden email]> 于2020年9月22日周二 上午9:52写道：

> Hi,
>
> 可以的，我看了下，你可以把你异常和可以复现的代码贴下吗？
>
> 祝好,
> Leonard
>
>
> > 在 2020年9月22日，09:44，nashcen <[hidden email]> 写道：
> >
> > 语法提示错误，就没有运行。在你们的IDEA里面，1.11 Table API 的& 写法，是否显示正常？
> >
> >
> >
> > --
> > Sent from: http://apache-flink.147419.n8.nabble.com/
>
>

[nashcen]

多谢，引入以下包解决了我的问题

import org.apache.flink.table.api._



--
Sent from: http://apache-flink.147419.n8.nabble.com/