Flink使用idea将匿名内部类替换为lambda表达会擦除泛型

2022-02-07

字数统计: 170字 | 阅读时长≈ 1分

Flink代码使用IDEA将new匿名内部类替换为lambda表达式运行会报错,因为替换后会擦除泛型

测试Flink1.12.0没有出现返回值类型报错问题. 不知道是否是Flink高版本结局了此问题还是idea高版本解决了此问题.

源码地址:™

https://github.com/ShangBaiShuYao/flink-learning-from-zhisheng/blob/main/flink-1.12.0-Demo/src/main/java/com/shangbaishuyao/demo/FlinkDemo01/Flink_WordCount_Bounded.java

报错类型示例

博客:www.xubatian.cn

返回值类型报错

博客:www.xubatian.cn

解决方式:

博客:www.xubatian.cn

聊聊Java泛型类型擦除及Flink类型暗示（type hint）机制

用Lambda写法有时候是需要指定returns的原因是Flink有自己的一套类型管理系统叫 typeInformation

本文作者： xubatian
本文链接： http://xubatian.cn/Flink使用idea将匿名内部类替换为lambda表达会擦除泛型/
版权声明： 本博客所有文章除特别声明外均为原创，采用 CC BY 4.0 CN协议许可协议。转载请注明出处:https://www.xubatian.cn/

jsonContent: meta: false pages: false posts: title: true date: true path: true text: false raw: false content: false slug: false updated: false comments: false link: false permalink: false excerpt: false categories: false tags: true