You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by nashcen <24...@qq.com> on 2020/09/21 10:23:07 UTC

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

在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/

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

Posted by nashcen <24...@qq.com>.
多谢，引入以下包解决了我的问题

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



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

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

Posted by 赵一旦 <hi...@gmail.com>.
首先确保你是1.11，因为1.10没有$函数。其次确保你import了$函数，在org.apache.flink.table.api.
Expressions类中。

Leonard Xu <xb...@gmail.com> 于2020年9月22日周二 上午9:52写道：

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

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

Posted by Leonard Xu <xb...@gmail.com>.
Hi,

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

祝好,
Leonard


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

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

Posted by nashcen <24...@qq.com>.
语法提示错误，就没有运行。在你们的IDEA里面，1.11 Table API 的& 写法，是否显示正常？



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

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

Posted by Leonard Xu <xb...@gmail.com>.
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>