这个问题之前一直也没想过,其实主要也是之前从来没有遇到过需要序列化它的情景,直到。。。
我在开发flink作业的时候,因为一些需求,需要传入一个自定义的过滤器,而自然而然就直接使用这种lambda写一通函数式编程又爽又好用,但启动后确是:
直接一手序列化报错给我整懵逼了, 恩? 原来lambda是不能序列化的吗,一般来说,一个普通的实体类,只需要给类实现一个Serializable的接口标明,就可以参与序列化了,但这种lambda怎么给接口呀?
但是我脑海中突然闪过一个之前好像看到过类似的实现:诶? 我记得。。
打开JDK TreeMap源码,找到getComparator方法:
@Override public Comparator> getComparator() { // Adapt or create a key-based comparator if (tree.comparator != null) { return Map.Entry.comparingByKey(tree.comparator); } else { return (Comparator > & Serializable) (e1, e2) -> { @SuppressWarnings("unchecked") Comparable super K> k1 = (Comparable super K>) e1.getKey(); return k1.compareTo(e2.getKey()); }; } }
这不就是活生生的教学案例吗?
之前看到的时候还想不明白这种return的用法是什么意思,现在忽然有一种恍然大悟的感觉。。。于是直接三下五除二照搬过来到我的代码:
Then,成了~~~
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)