Apache 1.0.0中是否支持引用方法？
Apache 1.0.0中是否支持引用方法？
提问于 2016-03-25 08:21:06
此代码运行良好：
.keyBy(value -> value.getSessionUid())但这是
.keyBy(LogItem::getSessionUid)抛出异常：
Exception in thread "main" java.lang.ArrayIndexOutOfBoundsException: -1
at org.apache.flink.api.java.typeutils.TypeExtractor.getUnaryOperatorReturnType(TypeExtractor.java:294)
at org.apache.flink.api.java.typeutils.TypeExtractor.getKeySelectorTypes(TypeExtractor.java:253)
at org.apache.flink.api.java.typeutils.TypeExtractor.getKeySelectorTypes(TypeExtractor.java:246)
at org.apache.flink.streaming.api.datastream.KeyedStream.<init>(KeyedStream.java:87)
at org.apache.flink.streaming.api.datastream.DataStream.keyBy(DataStream.java:241)
at streamer_sessions_aggregator.StreamerSessionAggregator.runFlow(StreamerSessionAggregator.java:40)
at streamer_sessions_aggregator.Main.main(Main.java:10)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:497)
at com.intellij.rt.execution.application.AppMain.main(AppMain.java:144)据我所知，Apache 1.0.0现在不支持引用方法。对吗？
回答 1
Stack Overflow用户
回答已采纳
发布于 2016-04-04 17:19:14
Flink目前不支持引用方法。下面是添加对它的支持的JIRA：https://issues.apache.org/jira/browse/FLINK-3138
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/36216418
复制相关文章
相似问题
腾讯云开发者
