回复：FlinkSQL 下推的值类型与字段类型不对应

[automths <au...@163.com>]

谢谢你的回答。
但是我的col1,col2就已经是SMALLINT类型的了，是where条件中值下推过程中是Integer类型的，我希望值也是SMALLINT的。



新年快乐！


| |
automths
|
|
邮箱：automths@163.com
|

签名由 网易邮箱大师 定制

在2020年12月31日 18:17，whirly 写道：
Hi.

查询语句中可以使用 cast 内置函数将值强制转换为指定的类型，如 select CAST(A.`col1` AS SMALLINT) as col1 from table


参考：
https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/functions/systemFunctions.html#type-conversion-functions
https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/types.html#data-types




best 2021.


在 2020-12-31 17:13:20，"automths" <au...@163.com> 写道：
>Hi：
>我自定义connect并实现了FilterableTableSource接口，可是发现flink planner 下推的Filter中， Literal类型与字段类型不匹配。
>比如：下面的SQL：
> select * from shortRow1 where key in (1, 2, 3) and col1 > 10 and col1 <= 15
>其中DDL定义时， key、col1、col1都是SMALLINT类型
>在下推的Filter中， GreaterThan中的Literal是Integer类型，这样是合理的吗？或者我的查询语句中要做什么处理？
>
>
>祝好！
>| |
>automths
>|
>|
>automths@163.com
>|
>