FlinkSQL 下推的值类型与字段类型不对应
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类型，这样是合理的吗？或者我的查询语句中要做什么处理？*来自志愿者整理的flink邮件归档
写回答
-
查询语句中可以使用 cast 内置函数将值强制转换为指定的类型，如 select CAST(A.
col1AS 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*来自志愿者整理的FLINK邮件归档2021-12-02 15:49:22赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
